org.nanoframework.concurrent.scheduler

类 SchedulerFactory

java.lang.Object

org.nanoframework.concurrent.scheduler.SchedulerFactory

public class SchedulerFactory
extends Object

任务工厂.

从以下版本开始:

1.3

作者:

yanghe

字段概要

字段

限定符和类型	字段和说明
static String	DEFAULT_SCHEDULER_NAME_PREFIX
static SchedulerThreadFactory	THREAD_FACTORY

方法概要

限定符和类型	方法和说明
void	addScheduler(BaseScheduler scheduler)
void	append(String groupName, int size, boolean autoStart)
BaseScheduler	bind(BaseScheduler scheduler) 绑定任务
void	close(BaseScheduler scheduler)
void	close(String id) 关闭任务
void	closeAll() 关闭所有任务
boolean	closed(String id)
void	closeGroup(String groupName) 关闭整组任务
void	destory()
BaseScheduler	find(String id)
BaseScheduler	findLast(String groupName)
Set<BaseScheduler>	getGroupScheduler(String groupName)
int	getGroupSize(String groupName)
static SchedulerFactory	getInstance()
Collection<BaseScheduler>	getStartedScheduler() 返回所有任务
int	getStartedSchedulerSize() 获取现在正在执行的任务数
Collection<BaseScheduler>	getStoppedScheduler()
int	getStoppedSchedulerSize()
Collection<BaseScheduler>	getStoppingScheduler()
int	getStoppingSchedulerSize()
boolean	hasClosedGroup(String group)
boolean	hasStartedGroup(String group)
static void	load() 加载任务调度
void	rebalance(String groupName)
void	removeGroup(String groupName)
int	removeScheduler(BaseScheduler scheduler)
int	removeScheduler(BaseScheduler scheduler, boolean force)
int	removeScheduler(String groupName)
void	start(String id)
void	startAll() 启动所有缓冲区中的任务并清理任务缓冲区
boolean	started(String id)
void	startGroup(String groupName)

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

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

字段详细资料

DEFAULT_SCHEDULER_NAME_PREFIX

public static final String DEFAULT_SCHEDULER_NAME_PREFIX

另请参阅:

常量字段值

THREAD_FACTORY

public static final SchedulerThreadFactory THREAD_FACTORY

方法详细资料

getInstance

public static SchedulerFactory getInstance()

bind

public BaseScheduler bind(BaseScheduler scheduler)

绑定任务

参数:

scheduler - 任务

返回:

返回当前任务

getStartedSchedulerSize

public int getStartedSchedulerSize()

获取现在正在执行的任务数

返回:

任务数

getStartedScheduler

public Collection<BaseScheduler> getStartedScheduler()

返回所有任务

返回:

任务集合

getStoppedSchedulerSize

public int getStoppedSchedulerSize()

getStoppedScheduler

public Collection<BaseScheduler> getStoppedScheduler()

getStoppingSchedulerSize

public int getStoppingSchedulerSize()

getStoppingScheduler

public Collection<BaseScheduler> getStoppingScheduler()

close

public void close(String id)

关闭任务

参数:

id - 任务号

close

public void close(BaseScheduler scheduler)

closeGroup

public void closeGroup(String groupName)

关闭整组任务

参数:

groupName - the groupName

closeAll

public void closeAll()

关闭所有任务

startAll

public void startAll()

启动所有缓冲区中的任务并清理任务缓冲区

startGroup

public void startGroup(String groupName)

start

public void start(String id)

append

public void append(String groupName,
                   int size,
                   boolean autoStart)

closed

public boolean closed(String id)

started

public boolean started(String id)

hasClosedGroup

public boolean hasClosedGroup(String group)

hasStartedGroup

public boolean hasStartedGroup(String group)

addScheduler

public void addScheduler(BaseScheduler scheduler)

removeScheduler

public int removeScheduler(BaseScheduler scheduler,
                           boolean force)

removeScheduler

public int removeScheduler(BaseScheduler scheduler)

removeScheduler

public int removeScheduler(String groupName)

removeGroup

public final void removeGroup(String groupName)

getGroupSize

public int getGroupSize(String groupName)

getGroupScheduler

public Set<BaseScheduler> getGroupScheduler(String groupName)

find

public final BaseScheduler find(String id)

findLast

public BaseScheduler findLast(String groupName)

rebalance

public void rebalance(String groupName)

load

public static final void load()
                       throws IllegalArgumentException,
                              IllegalAccessException

加载任务调度

抛出:

IllegalArgumentException - 非法的参数列表

IllegalAccessException - ?

destory

public void destory()