Issue
TLDR: I want to submit two lists of callables at the same time, but different timeout
Is there a way or the best alternative to running two invokeAll() commands at the same time with different timeouts?
Ex of blocking:
ExecutorService executorService1 = Executors.newFixedThreadPool(2);
ExecutorService executorService2 = Executors.newFixedThreadPool(2);
List<Callable<String>> callableTasks1;
List<Callable<String>> callableTasks2;
List<Future<String>> completed;
completed = executorService1.invokeAll(callableTasks1, 5, TimeUnit.Seconds);
completed.addAll(executorService1.invokeAll(callableTasks2, 2, TimeUnit.Seconds));
for(Future<String> s: completed) {
if(s.isCancelled()) {
System.out.println("It's cancelled");
} else {
try {
System.out.println("Got it: " + s.get());
}
catch(...) {
...
}
}
}
Submitting each task in a for loop: executorService1.submit(task) and calling task.get(5, TimeUnit.Seconds) seems to be running in sequence.
Solution
The solution I ended up with was waiting for the results from two threads. Also instead of creating two threads for each call I ended up using another executorService to reuse the threads
Shortened version(doesn't run, modify to run):
ExecutorService executorService1 = Executors.newFixedThreadPool(5);
ExecutorService executorService2 = Executors.newFixedThreadPool(2);
List<Callable<String>> callableTasks1 = new ArrayList(3 callables);
List<Callable<String>> callableTasks2 = new ArrayList(2 callables);
List<Callable<Object>> callableObjectFutures = executorService2.invokeAll(
() -> {executorService1.invokeAll(invokeAll(callableTasks1, 5, TimeUnit.Seconds);},
() -> {executorService1.invokeAll(invokeAll(callableTasks2, 2, TimeUnit.Seconds);}
);
List<Future<String>> completed = callableObjectFutures.get(0).get();
completed.addAll(callableObjectFutures.get(1).get());
Answered By - Gunther Answer Checked By - David Goodson (PHPFixing Volunteer)
0 Comments:
Post a Comment
Note: Only a member of this blog may post a comment.