From ccb422554a088ebf8d7a7fccd9324f249fcab0c4 Mon Sep 17 00:00:00 2001 From: byteblogs168 <598092184@qq.com> Date: Wed, 24 Jan 2024 18:36:34 +0800 Subject: [PATCH] =?UTF-8?q?feat:=202.6.0=201.=20=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E6=BB=91=E5=8A=A8=E7=AA=97=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../client/job/core/executor/JobExecutorFutureCallback.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/easy-retry-client/easy-retry-client-job-core/src/main/java/com/aizuda/easy/retry/client/job/core/executor/JobExecutorFutureCallback.java b/easy-retry-client/easy-retry-client-job-core/src/main/java/com/aizuda/easy/retry/client/job/core/executor/JobExecutorFutureCallback.java index c659acb9..54d1da33 100644 --- a/easy-retry-client/easy-retry-client-job-core/src/main/java/com/aizuda/easy/retry/client/job/core/executor/JobExecutorFutureCallback.java +++ b/easy-retry-client/easy-retry-client-job-core/src/main/java/com/aizuda/easy/retry/client/job/core/executor/JobExecutorFutureCallback.java @@ -64,8 +64,8 @@ public class JobExecutorFutureCallback implements FutureCallback } catch (Exception e) { EasyRetryLog.REMOTE.error("执行结果上报异常.[{}]", jobContext.getTaskId(), e); } finally { - stopThreadPool(); ThreadLocalLogUtil.removeContext(); + stopThreadPool(); } } @@ -92,8 +92,8 @@ public class JobExecutorFutureCallback implements FutureCallback } catch (Exception e) { EasyRetryLog.REMOTE.error("执行结果上报异常.[{}]", jobContext.getTaskId(), e); } finally { - stopThreadPool(); ThreadLocalLogUtil.removeContext(); + stopThreadPool(); } }