#Java - Usage of java.util.concurrent.Future

Search Java Code Snippets

Help us in improving the repository. Add new snippets through 'Submit Code Snippet ' link.

Submit Code Snippet

Java - Code Samples

Sample 1. Usage of java.util.concurrent.Future

long bytesLastMoved = bytesMoved.get();

Future<?>[] futures = new Future<?>[sources.size()];

int i=0;

for (Source source : sources) {

   futures[i++] = dispatcherExecutor.submit(source.new BlockMoveDispatcher());

}



for (Future<?> future : futures) {

   try {

      future.get();

   } catch (ExecutionException e) {

      LOG.warn("Dispatcher thread failed", e.getCause());

   }

}

_{Like Feedback}