org.nutz.runner

类 NutRunner

java.lang.Object

org.nutz.runner.NutRunner

所有已实现的接口:

Runnable

public abstract class NutRunner
extends Object
implements Runnable

封装Runnable的带lock的启动器

作者:

zozoh(zozohtnt@gmail.com), pw, wendal

字段概要

字段

限定符和类型	字段和说明
protected int	count 累积启动次数
protected Date	downAt 睡眠于，如果本值不为 null，表示本线程正在睡眠，否则为运行中
protected long	interval 本次睡眠时间
protected NutLock	lock 线程锁
protected Log	log
protected Thread	myThread 所属的关联线程
protected String	rnm 本运行器名称
protected int	sleepAfterError 报错以后睡眠时间
protected Date	upAt 启动于

构造器概要

构造器

构造器和说明
NutRunner(String rname) 新建一个启动器

方法概要

限定符和类型	方法和说明
void	afterStop(NutRunner me) 停止之后,一般是做一些资源回收
void	beforeStart(NutRunner me) 开始之前,一般做一些准备工作,比如资源初始化等
protected void	doIt() 做一些需要定期执行的操作
abstract long	exec() 具体的业务实现,返回一个sleep数
int	getCount() 获取累计的启动次数
Date	getDownAt() 获取最后一次等待开始的时间
long	getInterval() 获取执行间隔
NutLock	getLock() 获取线程NutLock锁
String	getName() 获取本启动器的名称
Date	getUpAt() 获取最后启动时间
boolean	isAlive() 获取所属线程是否存活
boolean	isRunning() 是否正在执行用户代码
boolean	isWaiting() 是否正在等待运行
void	reg(NutRunner me) 已过时。
void	run() 主逻辑,用户代码不应该覆盖.
NutRunner	setSleepAfterError(int sec) 设置报错以后睡眠时间（单位秒）
void	stop(Throwable err) 强行关闭所属线程
String	toString() 返回格式为 [名称:总启动次数] 最后启动时间:最后休眠时间 - 休眠间隔
void	unreg(NutRunner me) 已过时。

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

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

字段详细资料

log

protected Log log

myThread

protected Thread myThread

所属的关联线程

rnm

protected String rnm

本运行器名称

lock

protected NutLock lock

线程锁

count

protected int count

累积启动次数

interval

protected long interval

本次睡眠时间

sleepAfterError

protected int sleepAfterError

报错以后睡眠时间

upAt

protected Date upAt

启动于

downAt

protected Date downAt

睡眠于，如果本值不为 null，表示本线程正在睡眠，否则为运行中

构造器详细资料

NutRunner

public NutRunner(String rname)

新建一个启动器

参数:

rname - 本启动器的名称

方法详细资料

setSleepAfterError

public NutRunner setSleepAfterError(int sec)

设置报错以后睡眠时间（单位秒）

参数:

sec - 秒

返回:

冷却时间

run

public void run()

主逻辑,用户代码不应该覆盖.

指定者:

run 在接口中 Runnable

exec

public abstract long exec()
                   throws Exception

具体的业务实现,返回一个sleep数

返回:

本次运行后还需要等待多少个毫秒

抛出:

Exception

reg

@Deprecated
public void reg(NutRunner me)

已过时。

注册本对象到线程管理器,已废弃

参数:

me - 本对象

unreg

@Deprecated
public void unreg(NutRunner me)

已过时。

从线程管理器反注册,已废弃

参数:

me - 本对象

beforeStart

public void beforeStart(NutRunner me)

开始之前,一般做一些准备工作,比如资源初始化等

参数:

me - runner本身

afterStop

public void afterStop(NutRunner me)

停止之后,一般是做一些资源回收

参数:

me - runner本身

doIt

protected void doIt()

做一些需要定期执行的操作

toString

public String toString()

返回格式为 [名称:总启动次数] 最后启动时间:最后休眠时间 - 休眠间隔

覆盖:

toString 在类中 Object

isWaiting

public boolean isWaiting()

是否正在等待运行

返回:

true,如果正在等待

isRunning

public boolean isRunning()

是否正在执行用户代码

返回:

true,如果正在exec方法内部

getInterval

public long getInterval()

获取执行间隔

返回:

执行间隔

getUpAt

public Date getUpAt()

获取最后启动时间

返回:

最后启动时间

getDownAt

public Date getDownAt()

获取最后一次等待开始的时间

返回:

最后一次等待开始的时间

getName

public String getName()

获取本启动器的名称

返回:

本启动器的名称

getCount

public int getCount()

获取累计的启动次数

返回:

总启动次数

getLock

public NutLock getLock()

获取线程NutLock锁

返回:

线程NutLock锁

isAlive

public boolean isAlive()

获取所属线程是否存活

返回:

所属线程是否存活

stop

public void stop(Throwable err)

强行关闭所属线程

参数:

err - 传给Thread.stop方法的对象