处理器的最大不活跃时间，取调度平台作业最大时间的2倍

Author: nnhy

AntJob/Data/IJob.cs

@@ -30,6 +30,9 @@ public interface IJob
     /// <summary>并行度。最大同时执行任务数</summary>
     Int32 MaxTask { get; set; }
 
+    /// <summary>最大执行时间。超过该时间则认为执行器故障，将会把该任务分配给其它执行器</summary>
+    Int32 MaxTime { get; set; }
+
     /// <summary>调度模式。定时调度只要达到时间片开头就可以跑，数据调度要求达到时间片末尾才可以跑</summary>
     JobModes Mode { get; set; }
 

AntJob/Data/JobModel.cs

@@ -48,6 +48,10 @@ public partial class JobModel : ICloneable
     [XmlAttribute]
     public Int32 MaxTask { get; set; }
 
+    /// <summary>最大执行时间。超过该时间则认为执行器故障，将会把该任务分配给其它执行器</summary>
+    [XmlAttribute]
+    public Int32 MaxTime { get; set; }
+
     /// <summary>调度模式。定时调度只要达到时间片开头就可以跑，数据调度要求达到时间片末尾才可以跑</summary>
     [XmlAttribute]
     public JobModes Mode { get; set; }

AntJob/Scheduler.cs

@@ -277,6 +277,7 @@ public async Task<Boolean> Process()
             // 更新作业参数，并启动处理器
             handler.Job = job;
             if (job.Mode == 0) job.Mode = handler.Mode;
+            if (job.MaxTime > 0) handler.MaxInactiveTime = job.MaxTime * 2;
             if (!handler.Active)
             {
                 try

Samples/HisAgent/HelloJob.cs

@@ -1,5 +1,4 @@
 using System;
-using System.Collections;
 using System.Collections.Generic;
 using System.ComponentModel;
 using System.Diagnostics;
@@ -17,7 +16,11 @@ namespace HisAgent;
 [Description("简单的定时任务")]
 internal class HelloJob : Handler
 {
-    public HelloJob() => Job.Cron = "7/30 * * * * ?";
+    public HelloJob()
+    {
+        Job.Cron = "7/30 * * * * ?";
+        //MaxInactiveTime = 60;
+    }
 
     public override Int32 Execute(JobContext ctx)
     {
@@ -46,8 +49,10 @@ public override async Task<Int32> ExecuteAsync(JobContext ctx)
         http.SetUserAgent();
         var rs = await http.GetAsync<IDictionary<String, Object>>("/cube/info", new { state });
 
+        //await Task.Delay(90_000);
         if (rs.TryGetValue("state", out var value) && value is String str)
         {
+            WriteLog("返回状态：{0}", str);
             Trace.Assert(state == str, "返回状态不一致");
         }