com.jn.langx.util.concurrent.executor

类 StripedExecutor

java.lang.Object

com.jn.langx.util.concurrent.executor.StripedExecutor

所有已实现的接口:

Executor

public final class StripedExecutor
extends Object
implements Executor

The StripedExecutor internally uses a stripe of queues and each queue has its own private worker-thread. When a task is 'executed' on the StripedExecutor, the task is checked if it is a StripedRunnable. If it is, the right worker is looked up and the task put in the queue of that worker. If the task is not a StripedRunnable, a random worker is looked up.

If the queue is full and the runnable implements TimeoutRunnable, then a configurable amount of blocking is done on the queue. If the runnable doesn't implement TimeoutRunnable or when the blocking times out, then the task is rejected and a RejectedExecutionException is thrown.

字段概要

字段

限定符和类型	字段和说明
static AtomicLong	THREAD_ID_GENERATOR

构造器概要

构造器

构造器和说明
StripedExecutor(org.slf4j.Logger logger, String threadNamePrefix, int threadCount, int queueCapacity)
StripedExecutor(org.slf4j.Logger logger, String threadNamePrefix, int threadCount, int queueCapacity, boolean lazyThreads)

方法概要

限定符和类型	方法和说明
void	execute(Runnable task)
List<BlockingQueue<Runnable>>	getTaskQueues()
int	getWorkQueueSize() Returns the total number of tasks pending to be executed.
boolean	isLive() Checks if this StripedExecutor is alive (so not shut down).
long	processedCount() Returns the total number of processed events.
void	shutdown() Shuts down this StripedExecutor.

从类继承的方法 java.lang.Object

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

字段详细资料

THREAD_ID_GENERATOR

public static final AtomicLong THREAD_ID_GENERATOR

构造器详细资料

StripedExecutor

public StripedExecutor(org.slf4j.Logger logger,
                       String threadNamePrefix,
                       int threadCount,
                       int queueCapacity)

StripedExecutor

public StripedExecutor(org.slf4j.Logger logger,
                       String threadNamePrefix,
                       int threadCount,
                       int queueCapacity,
                       boolean lazyThreads)

方法详细资料

getWorkQueueSize

public int getWorkQueueSize()

Returns the total number of tasks pending to be executed.

返回:

total work queue size.

processedCount

public long processedCount()

Returns the total number of processed events.

shutdown

public void shutdown()

Shuts down this StripedExecutor.

No checking is done to see if the StripedExecutor already is shut down, so it should be called only once.

If there is any pending work, it will be thrown away.

isLive

public boolean isLive()

Checks if this StripedExecutor is alive (so not shut down).

返回:

live (true)

execute

public void execute(@NonNull
                    Runnable task)

指定者:

execute 在接口中 Executor

getTaskQueues

public List<BlockingQueue<Runnable>> getTaskQueues()