From d5bd256a3bc549a295c7e797a7a74bd3178c0529 Mon Sep 17 00:00:00 2001 From: liangjiajie Date: Sat, 26 Apr 2025 17:10:40 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8D=95=E8=AF=8D=E6=8B=BC=E5=86=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/xxl/job/core/thread/JobThread.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java index df33b8b0..7c10ee79 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java @@ -110,7 +110,7 @@ public class JobThread extends Thread{ TriggerParam triggerParam = null; try { - // to check toStop signal, we need cycle, so wo cannot use queue.take(), instand of poll(timeout) + // to check toStop signal, we need cycle, so we cannot use queue.take(), instead of poll(timeout) triggerParam = triggerQueue.poll(3L, TimeUnit.SECONDS); if (triggerParam!=null) { running = true; @@ -206,7 +206,7 @@ public class JobThread extends Thread{ if(triggerParam != null) { // callback handler info if (!toStop) { - // commonm + // common TriggerCallbackThread.pushCallBack(new HandleCallbackParam( triggerParam.getLogId(), triggerParam.getLogDateTime(),