新增任务超时自动取消功能

pull/26/head
leiyuan 4 years ago
parent bee8db3813
commit eff0d3f065
  1. 7
      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);
}

Loading…
Cancel
Save