任务添加超时和并行允许数量

models/job.go

@@ -25,13 +25,15 @@ const (
 // 需要执行的 cron cmd 命令
 // 注册到 /cronsun/cmd/groupName/<id>
 type Job struct {
-	ID      string     `json:"id"`
-	Name    string     `json:"name"`
-	Group   string     `json:"group"`
-	Command string     `json:"cmd"`
-	User    string     `json:"user"`
-	Rules   []*JobRule `json:"rules"`
-	Pause   bool       `json:"pause"` // 可手工控制的状态
+	ID        string     `json:"id"`
+	Name      string     `json:"name"`
+	Group     string     `json:"group"`
+	Command   string     `json:"cmd"`
+	User      string     `json:"user"`
+	Rules     []*JobRule `json:"rules"`
+	Pause     bool       `json:"pause"`     // 可手工控制的状态
+	Timeout   int64      `json:"timeout"`   // 任务执行时间超时设置，大于 0 时有效
+	Parallels int        `json:"parallels"` // 设置任务在单个节点上可以同时允许多少个，针对两次任务执行间隔比任务执行时间要长的任务启用
 
 	// 执行任务的结点，用于记录 job log
 	runOn string

web/ui/src/components/JobEdit.vue

@@ -31,6 +31,19 @@
         <input v-else type="text" v-model="job.user" placeholder="指定执行用户">
       </div>
     </div>
+    <div class="two fields">
+      <div class="field">
+        <label>超时设置（单位“秒”，0 表示不限制）</label>
+        <input type="number" ref="timeout" v-model:value="job.timeout" placeholder="任务执行超时时间">
+      </div>
+      <div class="field">
+        <label>并行数设置（0 表示不限制）</label>
+        <div class="ui icon input">
+          <input type="number" ref="parallels" v-model:value="job.parallels" placeholder="任务执行超时时间">
+          <i ref="parallelstip" class="large help circle link icon" data-position="top right" data-content="设置在单个节点上面同时可执行多少个任务，针对某些任务执行时间很长，但两次任务执行间隔较短时比较有用" data-variation="wide"></i>
+        </div>
+      </div>
+    </div>
     <div class="field">
       <span v-if="!job.rules || job.rules.length == 0"><i class="warning circle icon"></i>当前任务没有定时器，点击下面按钮来添加定时器</span>
     </div>
@@ -66,6 +79,8 @@ export default {
           user: '',
           cmd: '',
           pause: false,
+          parallels: 0,
+          timeout: 0,
           rules: []
         },
         error: ''
@@ -157,6 +172,8 @@ export default {
         vm.job.pause = !vm.job.pause;
       }
     });
+
+    $(this.$refs.parallelstip).popup();
   },
 
   components: {