1

我有问题,我默认设置并发(1)

    function execute(){ 
      queue.create(title, {
        title          : title + ' id(' + reportId + ')',
        options        : options,
        criteria       : criteria
      }).save();

      return new bluebird((resolve) => {
        queue.process(title, function(job, done){
          doExecute(job.data.options, job.data.criteria).then((rows) => {
            done();
            resolve(rows);
          })
        });
      });
    }
    .....
    return execute() // event click to add new job

但是,当我通过执行()添加新作业时,我在 kue 活动列表中看到新作业并再次添加,我只能在活动列表中无限添加它们,尽管我默认设置为并发( 1)。

这对我来说很完美,如果每个工作先进入 kue 非活动列表,然后再以 2 或 1 进入活动列表,我如何设置它

4

0 回答 0