update README.md.

This commit is contained in:
tianyaleixiaowu 2019-12-25 14:35:17 +08:00 committed by Gitee
parent ba3af042b4
commit 43b6d2106d

View File

@ -20,7 +20,36 @@
#### 基本组件
worker 一个最小的任务执行单元。通常是一个网络调用,或一段耗时操作
worker 一个最小的任务执行单元。通常是一个网络调用,或一段耗时操作。
TV两个泛型分别是入参和出参类型。
譬如该耗时操作入参是String执行完毕的结果是Integer那么就可以用泛型来定义。
多个不同的worker之间没有关联分别可以有不同的入参、出参类型。
```
/**
* 每个最小执行单元需要实现该接口
* @author wuweifeng wrote on 2019-11-19.
*/
public interface IWorker<T, V> {
/**
* 在这里做耗时操作如rpc请求、IO等
*
* @param object
* object
*/
V action(T object);
/**
* 超时、异常时,返回的默认值
* @return 默认值
*/
V defaultValue();
}
```
callBack对每个worker的回调。worker执行完毕后会回调该接口带着执行成功、失败、原始入参、和详细的结果。
@ -43,7 +72,9 @@ public interface ICallback<T, V> {
```
wrapper组合了worker和callback是一个最小的调度单元。通过编排wrapper之间的关系达到组合各个worker顺序的目的。
wrapper组合了worker和callback是一个 **最小的调度单元** 。通过编排wrapper之间的关系达到组合各个worker顺序的目的。
wrapper的泛型和worker的一样决定了入参和结果的类型。
```
WorkerWrapper<String, String> workerWrapper = new WorkerWrapper<>(w, "0", w);