org.voovan.tools.event

Class EventRunnerGroup

java.lang.Object

org.voovan.tools.event.EventRunnerGroup

public class EventRunnerGroup
extends Object

事件执行管理器

Constructor Summary

Constructors

Constructor and Description
EventRunnerGroup(ThreadPoolExecutor threadPoolExecutor, int size, boolean isSteal, Function<EventRunner,Object> attachmentSupplier) 构造方法

Method Summary

Modifier and Type	Method and Description
EventRunner	choseEventRunner() 选择一个时间执行器
EventRunner[]	getEventRunners()
ThreadPoolExecutor	getThreadPool()
boolean	isSteal()
static EventRunnerGroup	newInstance(String groupName, int size, boolean isSteal, int threadPriority, Function<EventRunner,Object> attachmentSupplier) 静态构造方法
void	setSteal(boolean steal)
EventTask	stealTask() 从任务最多的 EventRunner 窃取任务

Methods inherited from class java.lang.Object

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

Constructor Detail

EventRunnerGroup

public EventRunnerGroup(ThreadPoolExecutor threadPoolExecutor,
                        int size,
                        boolean isSteal,
                        Function<EventRunner,Object> attachmentSupplier)

构造方法

Parameters:

threadPoolExecutor - 用于分发任务执行的线程池

size - 容纳事件执行器的数量

isSteal - 是否允许任务窃取

attachmentSupplier - 事件执行器的附属对象构造器

Method Detail

isSteal

public boolean isSteal()

setSteal

public void setSteal(boolean steal)

getThreadPool

public ThreadPoolExecutor getThreadPool()

getEventRunners

public EventRunner[] getEventRunners()

choseEventRunner

public EventRunner choseEventRunner()

选择一个时间执行器

Returns:

事件执行器对象

stealTask

public EventTask stealTask()

从任务最多的 EventRunner 窃取任务

Returns:

EventTask 对象

newInstance

public static EventRunnerGroup newInstance(String groupName,
                                           int size,
                                           boolean isSteal,
                                           int threadPriority,
                                           Function<EventRunner,Object> attachmentSupplier)

静态构造方法

Parameters:

groupName - 事件执行器名称

size - 容纳事件执行器的数量

isSteal - 是否允许任务窃取

threadPriority - 线程优先级

attachmentSupplier - 事件执行器的附属对象构造器

Returns:

事件执行管理器