From eff0d3f06587d720ea24b55541fd6c286c05982a Mon Sep 17 00:00:00 2001
From: leiyuan <leiyuan@YZWB0304>
Date: Wed, 2 Mar 2022 11:17:41 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E4=BB=BB=E5=8A=A1=E8=B6=85?=
 =?UTF-8?q?=E6=97=B6=E8=87=AA=E5=8A=A8=E5=8F=96=E6=B6=88=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/DotXxlJob.Core/Queue/JobTaskQueue.cs | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/DotXxlJob.Core/Queue/JobTaskQueue.cs b/src/DotXxlJob.Core/Queue/JobTaskQueue.cs
index adf62a3..523049c 100644
--- a/src/DotXxlJob.Core/Queue/JobTaskQueue.cs
+++ b/src/DotXxlJob.Core/Queue/JobTaskQueue.cs
@@ -128,7 +128,12 @@ namespace DotXxlJob.Core
 
                             _jobLogger.Log("<br>----------- xxl-job job execute start -----------<br>----------- Param:{0}", triggerParam.ExecutorParams);
 
-                            result = await Executor.Execute(triggerParam, ct);
+                            var exectorToken = ct;
+                            if (triggerParam.ExecutorTimeout > 0)
+                            {
+                                exectorToken = CancellationTokenSource.CreateLinkedTokenSource(exectorToken, new CancellationTokenSource(triggerParam.ExecutorTimeout * 1000).Token).Token;
+                            }
+                            result = await Executor.Execute(triggerParam, exectorToken);
 
                             _jobLogger.Log("<br>----------- xxl-job job execute end(finish) -----------<br>----------- ReturnT:" + result.Code);
                         }