feat: 2.6.0
1. 优化滑动窗口
This commit is contained in:
parent
22bf6d0dd4
commit
ccb422554a
@ -64,8 +64,8 @@ public class JobExecutorFutureCallback implements FutureCallback<ExecuteResult>
|
|||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
EasyRetryLog.REMOTE.error("执行结果上报异常.[{}]", jobContext.getTaskId(), e);
|
EasyRetryLog.REMOTE.error("执行结果上报异常.[{}]", jobContext.getTaskId(), e);
|
||||||
} finally {
|
} finally {
|
||||||
stopThreadPool();
|
|
||||||
ThreadLocalLogUtil.removeContext();
|
ThreadLocalLogUtil.removeContext();
|
||||||
|
stopThreadPool();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -92,8 +92,8 @@ public class JobExecutorFutureCallback implements FutureCallback<ExecuteResult>
|
|||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
EasyRetryLog.REMOTE.error("执行结果上报异常.[{}]", jobContext.getTaskId(), e);
|
EasyRetryLog.REMOTE.error("执行结果上报异常.[{}]", jobContext.getTaskId(), e);
|
||||||
} finally {
|
} finally {
|
||||||
stopThreadPool();
|
|
||||||
ThreadLocalLogUtil.removeContext();
|
ThreadLocalLogUtil.removeContext();
|
||||||
|
stopThreadPool();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user