Package com.linkedin.alpini.base.concurrency

Class TimeoutProcessor

java.lang.Object

com.linkedin.alpini.base.concurrency.TimeoutProcessor

All Implemented Interfaces:

Executor

public class TimeoutProcessor
extends Object
implements Executor

More efficient handling of cancellable schedulable events. The default ScheduledExecutorService is designed to handle schedulable tasks where cancellation is rare. However, for the purposes of handling timeouts, we would prefer cancellation to be the common case and the tasks should be rarely run.

See Also:

• ScheduledExecutorService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TimeoutProcessor.TimeoutFuture

Constructor Summary

Constructors

Constructor	Description
TimeoutProcessor()
TimeoutProcessor(ResourceRegistry registry)
TimeoutProcessor(ResourceRegistry registry, boolean useTreeMap, int executorThreadCount)
TimeoutProcessor(ResourceRegistry registry, long tickingInterval, boolean useTreeMap, int executorThreadCount)

Method Summary

Modifier and Type	Method	Description
void	awaitTermination(int timeout, TimeUnit unit)
void	execute(Runnable command)
TimeoutProcessor.TimeoutFuture	schedule(Runnable task, long delay, TimeUnit unit)	Schedule a timeout event to occur after the specified delay
void	shutdownNow()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

TimeoutProcessor

public TimeoutProcessor()

TimeoutProcessor

public TimeoutProcessor(ResourceRegistry registry)

TimeoutProcessor

public TimeoutProcessor(ResourceRegistry registry,
 boolean useTreeMap,
 int executorThreadCount)

TimeoutProcessor

public TimeoutProcessor(ResourceRegistry registry,
 long tickingInterval,
 boolean useTreeMap,
 int executorThreadCount)

Method Details

toString

public String toString()

Overrides:

toString in class Object

schedule

public TimeoutProcessor.TimeoutFuture schedule(Runnable task,
 long delay,
 TimeUnit unit)

Schedule a timeout event to occur after the specified delay

Parameters:

task - Runnable event.

delay - delay time.

unit - unit of time delay.

Returns:

Cancellable TimeoutFuture.

See Also:

• ScheduledExecutorService.schedule(Runnable, long, java.util.concurrent.TimeUnit)

shutdownNow

public void shutdownNow()

See Also:

• ExecutorService.shutdownNow()

awaitTermination

public void awaitTermination(int timeout,
 TimeUnit unit)
                      throws InterruptedException

Parameters:

timeout - the maximum time to wait

unit - the time unit of the timeout argument

Throws:

InterruptedException - if interrupted while waiting

See Also:

• ExecutorService.awaitTermination(long, java.util.concurrent.TimeUnit)

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor