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 java.lang.Object implements Dispatcher
Pool dispatcher,wrap a threadpool.
-
-
Field Summary
Fields Modifier and Type Field Description static float
DEFAULT_MAX_POOL_SIZE_FACTOR
static int
DEFAULT_POOL_QUEUE_SIZE_FACTOR
private java.util.concurrent.ThreadPoolExecutor
threadPool
-
Constructor Summary
Constructors Constructor Description PoolDispatcher(int poolSize)
PoolDispatcher(int poolSize, int poolQueueSizeFactor, float maxPoolSizeFactor, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler, java.lang.String prefix)
PoolDispatcher(int poolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler, java.lang.String prefix)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
dispatch(java.lang.Runnable r)
void
stop()
-
-
-
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
-
threadPool
private java.util.concurrent.ThreadPoolExecutor threadPool
-
-
Constructor Detail
-
PoolDispatcher
public PoolDispatcher(int poolSize)
-
PoolDispatcher
public PoolDispatcher(int poolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler, java.lang.String prefix)
-
PoolDispatcher
public PoolDispatcher(int poolSize, int poolQueueSizeFactor, float maxPoolSizeFactor, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler, java.lang.String prefix)
-
-
Method Detail
-
dispatch
public final void dispatch(java.lang.Runnable r)
- Specified by:
dispatch
in interfaceDispatcher
-
stop
public void stop()
- Specified by:
stop
in interfaceDispatcher
-
-