org.apache.ambari.server.utils

Class ScheduledExecutorCompletionService<V>

java.lang.Object

java.util.concurrent.ExecutorCompletionService<V>

org.apache.ambari.server.utils.ScheduledExecutorCompletionService<V>

All Implemented Interfaces:

CompletionService<V>

public class ScheduledExecutorCompletionService<V>
extends ExecutorCompletionService<V>

Constructor Summary

Constructors

Constructor and Description
ScheduledExecutorCompletionService(ScheduledExecutorService scheduledExecutor, BlockingQueue<Future<V>> queue)

Method Summary

Modifier and Type	Method and Description
Future<V>	schedule(Callable<V> task, long delay, TimeUnit unit)

Methods inherited from class java.util.concurrent.ExecutorCompletionService

poll, poll, submit, submit, take

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledExecutorCompletionService

public ScheduledExecutorCompletionService(ScheduledExecutorService scheduledExecutor,
                                          BlockingQueue<Future<V>> queue)

Method Detail

schedule

public Future<V> schedule(Callable<V> task,
                          long delay,
                          TimeUnit unit)