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:当前线程