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.

Author:

dennis

Field Summary

Fields

Modifier and Type	Field and Description
static float	DEFAULT_MAX_POOL_SIZE_FACTOR
static int	DEFAULT_POOL_QUEUE_SIZE_FACTOR

Constructor Summary

Constructors

Constructor and 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

Methods

Modifier and Type	Method and Description
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 Detail

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

Constructor Detail

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 Detail

dispatch

public final void dispatch(Runnable r)

Specified by:

dispatch in interface Dispatcher

stop

public void stop()

Specified by:

stop in interface Dispatcher