From 89c3d5a42d80f327813bf04355c206f1e9852cca Mon Sep 17 00:00:00 2001 From: bryan31 Date: Mon, 8 Nov 2021 13:50:58 +0800 Subject: [PATCH] =?UTF-8?q?enhancement=20#I3DM92=20=E9=9B=86=E6=88=90async?= =?UTF-8?q?Tool=E4=BD=9C=E4=B8=BA=E7=BA=BF=E7=A8=8B=E7=BC=96=E6=8E=92?= =?UTF-8?q?=E7=9A=84=E6=A0=B8=E5=BF=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../yomahub/liteflow/asynctool/callback/DefaultCallback.java | 1 + .../liteflow/asynctool/callback/DefaultGroupCallback.java | 1 + .../java/com/yomahub/liteflow/asynctool/callback/ICallback.java | 1 + .../com/yomahub/liteflow/asynctool/callback/IGroupCallback.java | 1 + .../com/yomahub/liteflow/asynctool/callback/ITimeoutWorker.java | 1 + .../java/com/yomahub/liteflow/asynctool/callback/IWorker.java | 2 +- .../yomahub/liteflow/asynctool/exception/SkippedException.java | 1 + .../java/com/yomahub/liteflow/asynctool/executor/Async.java | 1 + .../yomahub/liteflow/asynctool/executor/timer/SystemClock.java | 1 + .../com/yomahub/liteflow/asynctool/worker/DependWrapper.java | 1 + .../java/com/yomahub/liteflow/asynctool/worker/ResultState.java | 1 + .../java/com/yomahub/liteflow/asynctool/worker/WorkResult.java | 1 + .../com/yomahub/liteflow/asynctool/wrapper/WorkerWrapper.java | 2 +- 13 files changed, 13 insertions(+), 2 deletions(-) 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 {