Master-Work高并发模式
2022-05-06 10:16:17 1 举报
参考尼恩卷2
作者其他创作
大纲/内容
index(AtomiInteger):Task初始值,用于新增
执行回调函数,由子类SimpleTask实现
workId:当前任务角色
Task<R>
SimpleTask doexecute()重写Task方法
创建初始化
Master-Work高并发模式
1:*
MasterWorkerTest
result:计算结果
workers集合
Consumer<Task<R>> resultAction回调函数
taskQueue:LinkedBlockingQueue接收任务的阻塞队列
resultMap任务处理结果集
taskQueue任务集合
thread当前线程
work编号:index(AtomicInteger),workerId(int)
thread:当前线程
收藏
0 条评论
回复 删除
下一页