dcs逻辑
2021-11-05 15:29:01 0 举报
逻辑
作者其他创作
大纲/内容
实现 Runnable 接口，重写run方法，构造reponse 对应，进行响应
无限循环，从queue 中取出response
PluginDataReceive
run()
实现 Runnable 接口，重写run方法，无限循环，从队列中取 request对象
ServerConnectThread
ExecuteQueueMgr
PluginServer
PluginServerClient
ServerConnectMgr
ResponseProcessThread
send(responses)
A
new PluginExecuteThread(request)
对请求 request 插件对象判断，request对象
向 RequestWorker 队列中添加 request work.addQueue(req)
内部SendTask类继承Thread类，重写run 方法，无限循环执行从队列中取response对象
ResponseWorker
pool.execute(new ServerConnectThread(responses))
实现 Runnable 接口，重写run方法，获取连接对象，发送响应
pool.execute(new ResponseProcessThread(data))
向观察者通知状态改变，进行响应
RequestWorker
ServerConnect
addQueue(req)
getInstance()
addToExecuteQueue(request)
add(response)
通过观察者模式，对象状态改变后，通知所有注册的观察者
execute(requests)
notify(response)
pool.execute(A)
sendData(response)
PluginResponseMgr
PluginExecuteThread
向queue 中添加response
构造 ConnectTread 对象，线程池中执行run 方法
0 条评论
回复 删除
下一页
