Waiting on a list of Future

by

You can use a CompletionService to receive the futures as soon as they are ready and if one of them throws an exception cancel the processing. Something like this:

Executor executor = Executors.newFixedThreadPool(4);
CompletionService<SomeResult> completionService = 
       new ExecutorCompletionService<SomeResult>(executor);

//4 tasks
for(int i = 0; i < 4; i++) {
   completionService.submit(new Callable<SomeResult>() {
       public SomeResult call() {
           ...
           return result;
       }
   });
}

int received = 0;
boolean errors = false;

while(received < 4 && !errors) {
      Future<SomeResult> resultFuture = completionService.take(); //blocks if none available
      try {
         SomeResult result = resultFuture.get();
         received ++;
         ... // do something with the result
      }
      catch(Exception e) {
             //log
         errors = true;
      }
}

I think you can further improve to cancel any still executing tasks if one of them throws an error.

More Related Contents:

  1. How to use invokeAll() to let all thread pool do their task?
  2. Java: Why main class does not extend Thread class [closed]
  3. What is the volatile keyword useful for?
  4. Using threads to make database requests
  5. wait until all threads finish their work in java
  6. How can I kill a thread? without using stop();
  7. Threads with Key Bindings
  8. When exactly do you use the volatile keyword in Java? [duplicate]
  9. Main Thread vs. UI Thread in Java
  10. Is a volatile int in Java thread-safe?
  11. Java Executors: how can I set task priority?
  12. How many threads are spawned in parallelStream in Java 8?
  13. How to Pause and Resume a Thread in Java from another Thread
  14. Volatile variable in Java
  15. When does the main thread stop in Java?
  16. When is a Java thread alive?
  17. How to stop a thread created by implementing runnable interface?
  18. Java Thread Example? [closed]
  19. How does `this` reference to an outer class escape through publishing inner class instance?
  20. Are non-synchronised static methods thread safe if they don’t modify static class variables?
  21. Any good Spring threading with a TaskExecutor examples? [closed]
  22. How do I prove programmatically that StringBuilder is not threadsafe?
  23. java download multiple files using threads
  24. AsyncTask.executeOnExecutor() before API Level 11
  25. Java getting download progress
  26. java.lang.OutOfMemoryError: unable to create new native thread error using ChromeDriver and Chrome through Selenium in Spring boot
  27. Is Cipher thread-safe?
  28. Write end dead exception using PipedInputStream java
  29. Why is Thread.stop() so dangerous
  30. How to test methods that call System.exit()?

Leave a Comment