Workq作业调度服务器
Workq 是一个用 Go 开发的作业调度服务器。主要特性:
异步和同步的作业处理
提交作业,然后在作业完成后返回结果,最多等待 TTL
提交作业并马上获得执行结果
在任意时间临时安排作业调度
使用数值表示作业优先级
可以制定每个作业的 TTR (time-to-run) - 限制最大执行时间
可以制定每个作业的 TTL 超时 - 限制作业最大存活时间
每个作业可单独设置重试策略,包括 max-attempts 和 max-fails 参数
示例代码:
job := &workq.FgJob{ ID: "6ba7b810-9dad-11d1-80b4-00c04fd430c4", Name: "ping", TTR: 5000, // 5 second time-to-run limit Timeout: 60000, // Wait up to 60 seconds for a worker to pick up. Payload: []byte("ping"), Priority: 10, // @OPTIONAL Numeric priority, default 0. } result, err := client.Run(job) if err != nil { // ... } fmt.Printf("Success: %t, Result: %s", result.Success, result.Result)
评论
Gearmand作业调度服务器
Gearmand是Gearman的作业服务器组件,Gearman是一个分发任务的程序框架,可以用在各种场合,与Hadoop相比,Gearman更偏向于任务分发功能。它的任务分布非常简单,简单得可以只需
Gearmand作业调度服务器
0
OddjobJava作业调度
Oddjob是一个采用Java语言开发的作业调度工具,通过图形化界面或者是XML文件进行任务的设定,支持按顺序执行、并行执行以及根据预设条件执行任务,可运行于桌面或者是服务器,可以通过JMX方式对其进
OddjobJava作业调度
0
Jobber作业调度工具
Jobber是一个类似Unix上的cron工具,是一个作业调度工具。除了包含cron的功能外,Jobber还提供:作业执行历史记录复杂的错误处理错误报告
Jobber作业调度工具
0