com.google.code.tempusfugit.concurrency
Class DefaultTimeoutableCompletionService

java.lang.Object
  com.google.code.tempusfugit.concurrency.DefaultTimeoutableCompletionService

All Implemented Interfaces:

TimeoutableCompletionService

public class DefaultTimeoutableCompletionService
extends Object
implements TimeoutableCompletionService

Constructor Summary

DefaultTimeoutableCompletionService(CompletionService completionService)

DefaultTimeoutableCompletionService(CompletionService completionService, Duration timeout, Clock time)

Method Summary

<T> List<T>

submit(List<? extends Callable<T>> tasks)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultTimeoutableCompletionService

public DefaultTimeoutableCompletionService(CompletionService completionService)

DefaultTimeoutableCompletionService

public DefaultTimeoutableCompletionService(CompletionService completionService,
                                           Duration timeout,
                                           Clock time)

Method Detail

submit

public <T> List<T> submit(List<? extends Callable<T>> tasks)
               throws ExecutionException,
                      TimeoutException

Specified by:

submit in interface TimeoutableCompletionService

Throws:

ExecutionException

TimeoutException