From d52d730162ea7f325173220bc2fc2b746b5cad16 Mon Sep 17 00:00:00 2001 From: sjsdfg <736777445@qq.com> Date: Fri, 12 Jun 2020 22:28:49 +0800 Subject: [PATCH] clean:clean code fragment --- .../jd/platform/async/executor/timer/SystemClock.java | 11 ++++------- .../com/jd/platform/async/wrapper/WorkerWrapper.java | 1 - 2 files changed, 4 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/jd/platform/async/executor/timer/SystemClock.java b/src/main/java/com/jd/platform/async/executor/timer/SystemClock.java index 12052f1..e65dd85 100644 --- a/src/main/java/com/jd/platform/async/executor/timer/SystemClock.java +++ b/src/main/java/com/jd/platform/async/executor/timer/SystemClock.java @@ -31,13 +31,10 @@ public class SystemClock { } private void scheduleClockUpdating() { - ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() { - @Override - public Thread newThread(Runnable runnable) { - Thread thread = new Thread(runnable, "System Clock"); - thread.setDaemon(true); - return thread; - } + ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(runnable -> { + Thread thread = new Thread(runnable, "System Clock"); + thread.setDaemon(true); + return thread; }); scheduler.scheduleAtFixedRate(() -> now.set(System.currentTimeMillis()), period, period, TimeUnit.MILLISECONDS); } 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 50f1c2b..4ee7e6b 100755 --- a/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java +++ b/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java @@ -281,7 +281,6 @@ public class WorkerWrapper { //上游都finish了，进行自己 fire(); beginNext(poolExecutor, now, remainTime); - return; } } -- Gitee