0

我正在创建一个守护进程,它将运行某些计划的日志记录任务,但我担心某些点会出现瓶颈。

实际上,我有一些我想每 15 分钟执行一次的日志记录任务,而有些我只想每 30 分钟执行一次,依此类推,直到每月只需要运行一次的任务。基本上,我有一个在每个时间间隔要进行的检查列表。这些被放入队列并由线程池处理。

目前我看到任务正在运行这样的东西

15
15, 30
15, 30, 60
15, 30, 60, 120
15, 30, 60, 120, 240...

这意味着如果守护程序在 00:00 开始,那么到 04:00 将有五个进程同时运行,这不是它的结束。目前这导致下一个计划为 15 分钟的任务运行缓慢,并且只能访问有限的带宽。

然而,任务不必按小时运行。因此,如果 15 分钟任务在整点运行,则 30 分钟可能会在整点后 5 分钟开始,以尽量减少重叠。甚至可以将两个 30 分钟的任务(例如 00:00 和 00:30)拆分为四个 15 分钟的过程,以减少受到“一次性”类型问题的影响,但这确实让我头晕目眩。

是否有任何众所周知的方法来管理此类问题?

4

2 回答 2

0

你绝对应该看看Quartz,尤其是cron风格触发器

干杯,

于 2012-10-18T07:26:55.117 回答
0

好吧,从长远来看(正如我从您的问题中看到的那样),您将不得不寻找类似quartz的东西。

除此之外,我还有更多的担忧和建议:

  1. 用于[ScheduledExecutorService][2]管理这些线程。即使使用ScheduledExecutorService, 看起来您也想以单独的时间间隔运行它们,而不管它们的执行时间如何。SchedulewithFixedRate而不是ScheduleWithFixedDelay.

  2. 即使你实现了这样的任何东西,你的逻辑也会fail if your threads start to run on multiple hosts。运行每小时线程的 2 台主机将每 30 分钟有效运行一次。

  3. 我宁愿有一个centralized management in terms of Database跟踪最后一次运行和所有。这ExecutorService将是可扩展的和准确的。

假设您有 1000 个计划,在数据库中创建 1000 行。

列会有点像这样

id, P_Key
ScheduleName, AnyIdentifier for the daemon to run or task to do.
lastRunTime, lastTime it was run.
granularity, 15 mins, 30 mins etc.

您可以保留CreationTimeModificationTime作为最佳实践。

于 2012-11-02T20:38:49.803 回答