public abstract class ThreadServer
extends java.lang.Object
implements java.lang.Runnable
限定符和类型 | 字段和说明 |
---|---|
protected boolean |
continueFlag
是否终止线程
|
protected boolean |
startFlag
是否即时触发
|
protected java.lang.String |
threadID
线程编号
|
构造器和说明 |
---|
ThreadServer()
构造函数
|
限定符和类型 | 方法和说明 |
---|---|
protected abstract void |
destroy()
服务的结束处理函数
|
java.lang.String |
getDescription()
描述信息
|
java.lang.Object |
getParameter()
运行时的参数
|
ThreadPort |
getPort()
线程端口信息
|
java.lang.Object |
getPortName()
线程端口的名称
|
java.lang.String |
getThreadID() |
protected abstract void |
init(java.lang.Object parameter)
服务的初始化函数
|
boolean |
isContinueFlag()
判断服务线程是否终止
|
boolean |
isStartFlag() |
void |
run()
多线程守护
|
protected abstract void |
service(java.lang.Object request)
服务处理函数
|
protected void |
setContinueFlag(boolean continueFlag)
服务结束标志
|
void |
setDescription(java.lang.String description) |
void |
setParameter(java.lang.Object parameter) |
void |
setPort(ThreadPort port) |
void |
setPortName(java.lang.Object portName) |
void |
setStartFlag(boolean startFlag) |
protected boolean startFlag
protected boolean continueFlag
protected java.lang.String threadID
public ThreadPort getPort()
public void setPort(ThreadPort port)
public java.lang.Object getPortName()
public void setPortName(java.lang.Object portName)
public java.lang.Object getParameter()
public void setParameter(java.lang.Object parameter)
protected void setContinueFlag(boolean continueFlag)
public boolean isContinueFlag()
public java.lang.String getDescription()
public void setDescription(java.lang.String description)
public java.lang.String getThreadID()
public boolean isStartFlag()
public void setStartFlag(boolean startFlag)
public void run()
run
在接口中 java.lang.Runnable
protected abstract void init(java.lang.Object parameter) throws java.lang.Exception
parameter
- 初始化时的参数TxnException
java.lang.Exception
protected abstract void destroy()
TxnException
protected abstract void service(java.lang.Object request) throws java.lang.Exception
request
- 请求数据TxnException
java.lang.Exception