clean:clean code fragment

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);
     }

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;
         }
     }