使用循环在Node.js中进行异步作业调度

Anand 发表于 Dev

阿南德

我有一个按时间间隔分组的JSON任务（请参阅参考资料unit），应该按every间隔将它们重复执行unit。

 items=[
           { 
                "unit" : "minute",
                "detail" :
                 [ 
                    {"every" : 3, task : "task1"}
                    {"every" : 4, task : "task2"}...
                 ] 
           },
           { 
                "unit" : "day",
                "detail" :
                 [ 
                    {"every" : 3, task : "task3"}
                    {"every" : 4, task : "task4"}...
                 ] 
           },..
    ]

我通过以下异步功能使用了node-cron来按每个every unit间隔计划它们，例如：task1应该每3分钟发生一次。

我尝试了这段代码：

var CronJob = require('cron').CronJob;
function cronify(callback) 
{
    for (var i in items)
    {
        for (var j in items[i].detail) {                        
            callback(items[i].unit,items[i].detail[j]);
        }
    }
}

cronify(function (duration, detail) {
    var when = '* * * * * *';
    switch(duration)
    {
        case 'minute' : 
            when = '* */'+detail.every+' * * * *';
            break;
        case 'hour' : 
            when = '* * */'+detail.every+' * * *';
            break;
        case 'day' :
            when = '* * * * */'+detail.every+' * *';
            break;
    }
    var job = new CronJob(when, function () {
        //Do the task for task
         }, null, true, "GMT");
    }        
});

但是问题是每一个任务每秒都会执行一次，而与通过unit和提到的持续时间无关every。

钒23

是的，如果您将星号（*）放在第二位，则在* * / 2 * * * *的情况下，任务将每隔奇数分钟执行一次。要每分钟运行一次任务，可以将秒数设置为0，而不是0 * / 2 * * * *。示例代码：

items = [{
    "unit": "minute",
    "detail": [{
        "every": 3,
        "task": "task1"
    }, {
        "every": 4,
        "task": "task2"
    }]
}, {
    "unit": "day",
    "detail": [{
        "every": 3,
        task: "task3"
    }, {
        "every": 4,
        task: "task4"
    }]
}];
var CronJob = require('cron').CronJob;
function cronify(callback) {
    for (var i in items) {
        for (var j in items[i].detail) {
            callback(items[i].unit, items[i].detail[j]);
        }
    }
}
cronify(function(duration, detail) {
    var when = '* * * * * *';
    switch (duration) {
        case 'minute':
            when = '0 */' + detail.every + ' * * * *';
            break;
        case 'hour':
            when = '0 0 */' + detail.every + ' * * *';
            break;
        case 'day':
            when = '0 0 0 0 */' + detail.every + ' *';
            break;
    }
    var job = new CronJob(when, function (when) {
            console.log(when);
         }, null, true, "GMT");
});