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 12052f1e191146e4f88d8bc31a0a8c6f9331d057..e65dd8578d3318f2375747d738eddf77e7a7bf8e 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 50f1c2b7d1bbc32b0711c82d4798b904c901b576..4ee7e6bb9642da286d091e78ff800744af37aa87 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<T, V> {
             //上游都finish了，进行自己
             fire();
             beginNext(poolExecutor, now, remainTime);
-            return;
         }
     }