mirrors/asyncTool
1
0
Fork 0
mirror of https://gitee.com/jd-platform-opensource/asyncTool.git synced 2024-12-31 15:35:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

!1 Feat：clean code fragement

Browse Source 
Merge pull request !1 from 寒沧丶/clean
This commit is contained in:
tianyaleixiaowu 2020-06-12 22:49:00 +08:00 committed by Gitee
commit 96c6a8490f
2 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/com/jd/platform/async/executor/timer/SystemClock.java
View File

@ -31,13 +31,10 @@ public class SystemClock {
} }
private void scheduleClockUpdating() { private void scheduleClockUpdating() {
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(new ThreadFactory() { ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor(runnable -> {
@Override Thread thread = new Thread(runnable, "System Clock");
public Thread newThread(Runnable runnable) { thread.setDaemon(true);
Thread thread = new Thread(runnable, "System Clock"); return thread;
thread.setDaemon(true);
return thread;
}
}); });
scheduler.scheduleAtFixedRate(() -> now.set(System.currentTimeMillis()), period, period, TimeUnit.MILLISECONDS); scheduler.scheduleAtFixedRate(() -> now.set(System.currentTimeMillis()), period, period, TimeUnit.MILLISECONDS);
} }

1
src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java
View File

@ -281,7 +281,6 @@ public class WorkerWrapper<T, V> {
//上游都finish了，进行自己 //上游都finish了，进行自己
fire(); fire();
beginNext(poolExecutor, now, remainTime); beginNext(poolExecutor, now, remainTime);
return;
} }
} }