com.seeyon.ctp.thread

类 ThreadPort

java.lang.Object

com.seeyon.ctp.thread.ThreadPort

public class ThreadPort
extends java.lang.Object

线程执行端口

字段概要

字段

限定符和类型	字段和说明
protected static long	flowNo 当前流水号
protected java.lang.Object	lock
protected static org.apache.commons.logging.Log	LOGGER
protected java.lang.Object	portName 名称
protected ExChangeQueue	queue 交换队列
protected java.util.concurrent.Semaphore	sem 临界数据
protected ThreadServer	server 当前执行服务

构造器概要

构造器

构造器和说明
ThreadPort()

方法概要

限定符和类型	方法和说明
void	block() 阻塞
void	blockExecute() 阻塞执行，只在Block模式下起作用
void	call(java.lang.Object request) 调用
void	close()
void	decreaseTask() 减少任务
static java.lang.String	getId()
ExChangeQueue	getQueue()
ThreadRequest	getRequest() 从队列取第一个数据
int	getTask()
void	increaseTask() 增加任务
boolean	isBlockRunning()
protected void	send(java.lang.String id, java.lang.Object data) 增加请求数据
void	setBlockRunning(boolean _blockRunning)
void	startService(java.lang.Object portName, ThreadServer server) 启动服务
void	stopService() 关闭服务
protected void	unblock() 取消阻塞

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

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

字段详细资料

LOGGER

protected static org.apache.commons.logging.Log LOGGER

lock

protected final java.lang.Object lock

server

protected ThreadServer server

当前执行服务

flowNo

protected static long flowNo

当前流水号

portName

protected java.lang.Object portName

名称

queue

protected ExChangeQueue queue

交换队列

sem

protected java.util.concurrent.Semaphore sem

临界数据

构造器详细资料

ThreadPort

public ThreadPort()

方法详细资料

isBlockRunning

public boolean isBlockRunning()

setBlockRunning

public void setBlockRunning(boolean _blockRunning)

getQueue

public ExChangeQueue getQueue()

getTask

public int getTask()

send

protected void send(java.lang.String id,
                    java.lang.Object data)

增加请求数据

参数:

data -

call

public void call(java.lang.Object request)
          throws java.lang.Exception

调用

参数:

request -

抛出:

java.lang.Exception

getRequest

public ThreadRequest getRequest()
                         throws java.lang.InterruptedException

从队列取第一个数据

返回:

抛出:

java.lang.InterruptedException

getId

public static java.lang.String getId()

返回:

java.lang.String

increaseTask

public void increaseTask()

增加任务

decreaseTask

public void decreaseTask()

减少任务

startService

public void startService(java.lang.Object portName,
                         ThreadServer server)

启动服务

参数:

portName -

server -

stopService

public void stopService()

关闭服务

blockExecute

public void blockExecute()
                  throws java.lang.Exception

阻塞执行，只在Block模式下起作用

抛出:

java.lang.Exception

close

public void close()

block

public void block()

阻塞

unblock

protected void unblock()

取消阻塞