我正在使用 meteor-job-collection 并定义了一个 Worker
var workers = Job.processJobs( 'jobQueue', 'insertItems',
function ( job, cb ) {
// iterate
job.data.forEach( function ( item ) {
// insert
} );
// when done successfully
job.done();
// invoke the callback when work on this job has finished
return cb();
}
);
似乎我的服务器一直挂起，直到作业被处理完毕 . 我做错了什么吗？我应该将它包含在 wrapAsync 或 Tracker.autorun 中吗？
1 回答
根据文档，您应该使用
options.concurrency来增加一次可以处理的并发作业数量 . 查看meteor-job-collection文档的屏幕截图：