类 MsgHelper
java.lang.Object
top.yqingyu.common.qymsg.MsgHelper
- 所有已实现的接口:
Runnable
- 版本:
- 1.0.0
- 作者:
- YYJ
-
构造器概要
构造器构造器说明MsgHelper(BlockingQueue<QyMsg> inQueue, BlockingQueue<QyMsg> outQueue, AtomicBoolean running, int clearTime) -
方法概要
修饰符和类型方法说明static Stringstatic ObjectgainMsgOBJ(QyMsg msg, String key) static StringgainMsgValue(QyMsg msg, String key) static ObjectgainObjMsg(QyMsg msg) static voidinit(BlockingQueue<QyMsg> inQueue, BlockingQueue<QyMsg> outQueue, String thName, AtomicBoolean running, int clearTime) voidrun()
-
构造器详细资料
-
MsgHelper
public MsgHelper(BlockingQueue<QyMsg> inQueue, BlockingQueue<QyMsg> outQueue, AtomicBoolean running, int clearTime)
-
-
方法详细资料
-
gainMsg
-
gainObjMsg
-
gainMsgValue
-
gainMsgOBJ
-
init
public static void init(BlockingQueue<QyMsg> inQueue, BlockingQueue<QyMsg> outQueue, String thName, AtomicBoolean running, int clearTime) - 参数:
inQueue- 输入队列outQueue- 输出队列thName- 线程名称running- 运行
-
run
public void run()
-