Package com.google.code.yanf4j.core.impl

Class PoolDispatcher

java.lang.Object

com.google.code.yanf4j.core.impl.PoolDispatcher

All Implemented Interfaces:

Dispatcher

public class PoolDispatcher
extends Object
implements Dispatcher

Pool dispatcher,wrap a threadpool.

Field Summary

Fields

Modifier and Type	Field	Description
static final float	DEFAULT_MAX_POOL_SIZE_FACTOR
static final int	DEFAULT_POOL_QUEUE_SIZE_FACTOR
private ThreadPoolExecutor	threadPool

Constructor Summary

Constructors

Constructor	Description
PoolDispatcher(int poolSize)
PoolDispatcher(int poolSize, int poolQueueSizeFactor, float maxPoolSizeFactor, long keepAliveTime, TimeUnit unit, RejectedExecutionHandler rejectedExecutionHandler, String prefix)
PoolDispatcher(int poolSize, long keepAliveTime, TimeUnit unit, RejectedExecutionHandler rejectedExecutionHandler, String prefix)

Method Summary

Modifier and Type	Method	Description
final void	dispatch(Runnable r)
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_POOL_QUEUE_SIZE_FACTOR

public static final int DEFAULT_POOL_QUEUE_SIZE_FACTOR

See Also:

• Constant Field Values

DEFAULT_MAX_POOL_SIZE_FACTOR

public static final float DEFAULT_MAX_POOL_SIZE_FACTOR

See Also:

• Constant Field Values

threadPool

private ThreadPoolExecutor threadPool

Constructor Details

PoolDispatcher

public PoolDispatcher(int poolSize)

PoolDispatcher

public PoolDispatcher(int poolSize,
 long keepAliveTime,
 TimeUnit unit,
 RejectedExecutionHandler rejectedExecutionHandler,
 String prefix)

PoolDispatcher

public PoolDispatcher(int poolSize,
 int poolQueueSizeFactor,
 float maxPoolSizeFactor,
 long keepAliveTime,
 TimeUnit unit,
 RejectedExecutionHandler rejectedExecutionHandler,
 String prefix)

Method Details

dispatch

public final void dispatch(Runnable r)

Specified by:

dispatch in interface Dispatcher

stop

public void stop()

Specified by:

stop in interface Dispatcher