diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/DefaultCallback.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/DefaultCallback.java index 6f5db0cbb..294308a0c 100755 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/DefaultCallback.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/DefaultCallback.java @@ -3,6 +3,7 @@ package com.yomahub.liteflow.asynctool.callback; import com.yomahub.liteflow.asynctool.worker.WorkResult; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 默认回调类,如果不设置的话,会默认给这个回调 * @author wuweifeng wrote on 2019-11-19. */ diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/DefaultGroupCallback.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/DefaultGroupCallback.java index edec1bbb5..43a6821c8 100644 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/DefaultGroupCallback.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/DefaultGroupCallback.java @@ -5,6 +5,7 @@ import com.yomahub.liteflow.asynctool.wrapper.WorkerWrapper; import java.util.List; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * @author wuweifeng wrote on 2019-12-27 * @version 1.0 */ diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/ICallback.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/ICallback.java index 4576a9221..8be6899c9 100755 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/ICallback.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/ICallback.java @@ -4,6 +4,7 @@ package com.yomahub.liteflow.asynctool.callback; import com.yomahub.liteflow.asynctool.worker.WorkResult; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 每个执行单元执行完毕后,会回调该接口

* 需要监听执行结果的,实现该接口即可 * diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/IGroupCallback.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/IGroupCallback.java index 77d8f4650..a36a6a070 100755 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/IGroupCallback.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/IGroupCallback.java @@ -5,6 +5,7 @@ import com.yomahub.liteflow.asynctool.wrapper.WorkerWrapper; import java.util.List; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 如果是异步执行整组的话,可以用这个组回调。不推荐使用 * @author wuweifeng wrote on 2019-11-19. */ diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/ITimeoutWorker.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/ITimeoutWorker.java index de62611eb..42fc1e291 100644 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/ITimeoutWorker.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/ITimeoutWorker.java @@ -1,6 +1,7 @@ package com.yomahub.liteflow.asynctool.callback; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * @author wuweifeng wrote on 2019-12-20 * @version 1.0 */ diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/IWorker.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/IWorker.java index 54ac7ff50..9b520bf01 100755 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/IWorker.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/callback/IWorker.java @@ -5,8 +5,8 @@ import com.yomahub.liteflow.asynctool.wrapper.WorkerWrapper; import java.util.Map; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 每个最小执行单元需要实现该接口 - * * @author wuweifeng wrote on 2019-11-19. */ @FunctionalInterface diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/exception/SkippedException.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/exception/SkippedException.java index 0afceaacb..edf9332c5 100644 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/exception/SkippedException.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/exception/SkippedException.java @@ -1,6 +1,7 @@ package com.yomahub.liteflow.asynctool.exception; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 如果任务在执行之前,自己后面的任务已经执行完或正在被执行,则抛该exception * @author wuweifeng wrote on 2020-02-18 * @version 1.0 diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/executor/Async.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/executor/Async.java index d76b6b752..1d8b2accd 100644 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/executor/Async.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/executor/Async.java @@ -9,6 +9,7 @@ import java.util.concurrent.*; import java.util.stream.Collectors; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 类入口,可以根据自己情况调整core线程的数量 * @author wuweifeng wrote on 2019-12-18 * @version 1.0 diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/executor/timer/SystemClock.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/executor/timer/SystemClock.java index ce1210dc6..8eacb2381 100644 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/executor/timer/SystemClock.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/executor/timer/SystemClock.java @@ -6,6 +6,7 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 用于解决高并发下System.currentTimeMillis卡顿 * @author lry */ diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/DependWrapper.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/DependWrapper.java index 40c781f1f..22d3d5764 100644 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/DependWrapper.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/DependWrapper.java @@ -3,6 +3,7 @@ package com.yomahub.liteflow.asynctool.worker; import com.yomahub.liteflow.asynctool.wrapper.WorkerWrapper; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 对依赖的wrapper的封装 * @author wuweifeng wrote on 2019-12-20 * @version 1.0 diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/ResultState.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/ResultState.java index fa3643e41..78f903541 100755 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/ResultState.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/ResultState.java @@ -1,6 +1,7 @@ package com.yomahub.liteflow.asynctool.worker; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 结果状态 * @author wuweifeng wrote on 2019-11-19. */ diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/WorkResult.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/WorkResult.java index 1bb02f7de..b03153bcc 100755 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/WorkResult.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/worker/WorkResult.java @@ -1,6 +1,7 @@ package com.yomahub.liteflow.asynctool.worker; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 执行结果 */ public class WorkResult { diff --git a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/wrapper/WorkerWrapper.java b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/wrapper/WorkerWrapper.java index aeed8c6ce..d4010d439 100755 --- a/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/wrapper/WorkerWrapper.java +++ b/liteflow-async-tool/src/main/java/com/yomahub/liteflow/asynctool/wrapper/WorkerWrapper.java @@ -17,8 +17,8 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.atomic.AtomicInteger; /** + * 代码来自于asyncTool,请参考:https://gitee.com/jd-platform-opensource/asyncTool * 对每个worker及callback进行包装,一对一 - * * @author wuweifeng wrote on 2019-11-19. */ public class WorkerWrapper {