Package | Description |
---|---|
org.tinygroup.tinypc | |
org.tinygroup.tinypc.impl |
Modifier and Type | Method and Description |
---|---|
Warehouse |
WorkCombiner.combine(List<Warehouse> warehouseList)
把所有工人的执行结果再放到work的输出仓库中
|
Warehouse |
JobCenter.doWork(Work work)
执行一项工作,期望同步得到结果或异常 如果没有合适的工人或包工头进行处理,马上会抛出异常
|
Warehouse |
Work.getInputWarehouse()
返回输入仓库
|
Warehouse |
Worker.work(Work work)
执行工作
|
Warehouse |
Foreman.work(Work work,
List<Worker> workerList)
开始干活以完成工作
|
Modifier and Type | Method and Description |
---|---|
List<Warehouse> |
WorkSplitter.split(Work work,
List<Worker> workers)
把一个任务分解为多个任务
|
Modifier and Type | Method and Description |
---|---|
void |
Warehouse.putSubWarehouse(Warehouse warehouse) |
void |
Work.setInputWarehouse(Warehouse inputWarehouse)
设置输入仓库
|
Modifier and Type | Method and Description |
---|---|
Warehouse |
WorkCombiner.combine(List<Warehouse> warehouseList)
把所有工人的执行结果再放到work的输出仓库中
|
Modifier and Type | Class and Description |
---|---|
class |
WarehouseDefault
Created by luoguo on 14-1-8.
|
Modifier and Type | Method and Description |
---|---|
protected abstract Warehouse |
AbstractWorker.doWork(Work work)
真正的工作处理,在这里,如果提供取消工作需要对isCancel()的值进行判断,
如果是true的时候,表示要停止处理,这个时候要立即返回
|
Warehouse |
AbstractJobCenter.doWork(Work work) |
Warehouse |
WorkDefault.getInputWarehouse() |
Warehouse |
AbstractWorker.work(Work work) |
Warehouse |
ForemanSelectOneWorker.work(Work work,
List<Worker> workerList) |
Warehouse |
ForemanSelectAllWorker.work(Work work,
List<Worker> workerList) |
Modifier and Type | Method and Description |
---|---|
void |
WarehouseDefault.putSubWarehouse(Warehouse warehouse) |
void |
WorkDefault.setInputWarehouse(Warehouse inputWarehouse) |
Constructor and Description |
---|
WorkDefault(String type,
String id,
Warehouse inputWarehouse) |
WorkDefault(String type,
Warehouse inputWarehouse) |
Constructor and Description |
---|
WorkExecutor(Work work,
Worker worker,
List<Warehouse> warehouseList,
List<Worker> workers) |
Copyright © 2006–2018 TinyGroup. All rights reserved.