Field Detail

• retryingCallerFactory

  private final RpcRetryingCallerFactory retryingCallerFactory

• executor

  private final Executor executor

• tasks

  private final ResultBoundedCompletionService.QueueingFuture<V>[] tasks

• completed

  private volatile ResultBoundedCompletionService.QueueingFuture<V> completed

• cancelled

  private volatile boolean cancelled

Constructor Detail

• ResultBoundedCompletionService

  public ResultBoundedCompletionService(RpcRetryingCallerFactory retryingCallerFactory,
                                Executor executor,
                                int maxTasks)

Method Detail

• submit

  public void submit(RetryingCallable<V> task,
            int callTimeout,
            int id)

• take

  public ResultBoundedCompletionService.QueueingFuture<V> take()
                                                        throws InterruptedException

  Throws:

  InterruptedException

• poll

  public ResultBoundedCompletionService.QueueingFuture<V> poll(long timeout,
                                                      TimeUnit unit)
                                                        throws InterruptedException

  Throws:

  InterruptedException

• cancelAll

  public void cancelAll()