From a8f65100aa0663b6f49cfe622edc38d61f85f506 Mon Sep 17 00:00:00 2001 From: wuweifeng10 Date: Mon, 13 Jun 2022 10:01:50 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A0=BC=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java b/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java index 8f52d51..fa9973d 100755 --- a/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java +++ b/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java @@ -218,7 +218,7 @@ public class WorkerWrapper { private synchronized void doDependsJobs(ExecutorService executorService, List dependWrappers, WorkerWrapper fromWrapper, long now, long remainTime) { //如果当前任务已经完成了,依赖的其他任务拿到锁再进来时,不需要执行下面的逻辑了。 if (getState() != INIT) { - return ; + return; } boolean nowDependIsMust = false; //创建必须完成的上游wrapper集合