net.spy.concurrent
Class ScheduledExecutorCompletionService<V>

java.lang.Object
  net.spy.concurrent.RetryableExecutorCompletionService<V>
      net.spy.concurrent.ScheduledExecutorCompletionService<V>

Type Parameters:

V -

All Implemented Interfaces:

CompletionService<V>, ScheduledCompletionService<V>

public class ScheduledExecutorCompletionService<V>
extends RetryableExecutorCompletionService<V>
implements ScheduledCompletionService<V>

Completion service that allows completion tracking on scheduled items as well as

Constructor Summary

ScheduledExecutorCompletionService(ScheduledExecutorService ex)

Method Summary

Future<V>	schedule(Callable<V> c, long d, TimeUnit unit) Schedule a callable to be run in the future.
Future<?>	schedule(Runnable r, long d, TimeUnit unit) Schedule a runnable to be run in the future.

Methods inherited from class net.spy.concurrent.RetryableExecutorCompletionService

poll, poll, submit, submit, take

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.CompletionService

poll, poll, submit, submit, take

Constructor Detail

ScheduledExecutorCompletionService

public ScheduledExecutorCompletionService(ScheduledExecutorService ex)

Method Detail

schedule

public Future<V> schedule(Callable<V> c,
                          long d,
                          TimeUnit unit)

Description copied from interface: ScheduledCompletionService

Schedule a callable to be run in the future.

Specified by:

schedule in interface ScheduledCompletionService<V>

Parameters:

c - the callable

d - how long to wait

unit - time unit for the delay

Returns:

the future to track the result

schedule

public Future<?> schedule(Runnable r,
                          long d,
                          TimeUnit unit)

Description copied from interface: ScheduledCompletionService

Schedule a runnable to be run in the future.

Specified by:

schedule in interface ScheduledCompletionService<V>

Parameters:

r - the runnable

d - how long to wait

unit - time unit for the delay

Returns:

the future to track the result