stu/asyncTool
1
0
Fork 0
mirror of https://gitee.com/jd-platform-opensource/asyncTool.git synced 2026-03-22 04:27:15 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactor: 合并相同逻辑的函数

Browse Source
This commit is contained in:
kyle
2022-06-30 15:32:17 +08:00
parent b181ac72fe
commit efa4a9f46c
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
asyncTool-core/src/main/java/com/jd/platform/async/wrapper/WorkerWrapper.java
View File

@@ -264,16 +264,16 @@ public abstract class WorkerWrapper<T, V> {
}
}
};
final Runnable __function__callbackResultOfFalse_beginNext =
() -> {
__function__callbackResult.accept(false);
final Consumer<Boolean> __function__callbackResultOfFalse_beginNext =
(success) -> {
__function__callbackResult.accept(success);
beginNext(executorService, now, remainTime, group);
};
final BiConsumer<Boolean, Exception> __function__fastFail_callbackResult$false_beginNext =
(fastFail_isTimeout, fastFail_exception) -> {
boolean isEndsNormally = fastFail_exception instanceof EndsNormallyException;
fastFail(fastFail_isTimeout && !isEndsNormally, fastFail_exception, isEndsNormally);
__function__callbackResultOfFalse_beginNext.run();
__function__callbackResultOfFalse_beginNext.accept(false);
};
final Runnable __function__doWork =
() -> {
@@ -281,8 +281,7 @@ public abstract class WorkerWrapper<T, V> {
try {
if (fire(group)) {
if (setState(state, WORKING, AFTER_WORK)) {
__function__callbackResult.accept(true);
beginNext(executorService, now, remainTime, group);
__function__callbackResultOfFalse_beginNext.accept(true);
}
}
} catch (Exception e) {
@@ -306,6 +305,7 @@ public abstract class WorkerWrapper<T, V> {
// 总的已经超时了，就快速失败，进行下一个
if (remainTime <= 0) {
if (setState(state, states_of_beforeWorkingEnd, ERROR, null)) {
System.out.println("快速失败");
__function__fastFail_callbackResult$false_beginNext.accept(true, null);
}
return;

2
asyncTool-openutil/src/main/java/com/jd/platform/async/openutil/timer/HashedWheelTimer.java
View File

@@ -315,7 +315,7 @@ public class HashedWheelTimer extends AbstractWheelTimer {
startTimeInitialized.countDown();
do {
//TODO 时间轮这里结束不了任务
//TODO 时间轮这里一直执行，结束不了任务
final long deadline = waitForNextTick();
if (deadline > 0) {
int idx = (int) (tick & mask);