并行执行包含共同包装生成器的 Promise

Question

我正在为我的数据库创建种子数据。种子函数是co-wrapped generator(https://www.npmjs.com/package/co):

createSeedData () {
  co(function * () {
     [...]
  }
}

我曾尝试创建 40 个拍卖，每个拍卖一次出价。到目前为止，我有一个这样的 for 循环：

for (let i = 0; i <= 40; i++) {
  let auction = yield auction.create({
     [...]
  })  // Async creation of model and persisting it in db 
  yield bid.create({
    auction: auction.id
    [...]
  })
}

现在我想并行创建拍卖，但我无法让它正常工作。

co yield 与数组一起使用时支持并行执行。

但是我仍然需要先创建发票，然后使用收益率对其进行出价。

我尝试将上面的代码包装在一个 Promise 和一个内部共同包装的生成器函数中，但它永远不会完成执行。

我该如何解决这个问题？（如果可能的话不使用更多的包）

这是我对内部生成器的尝试：

let promises = []
for (let i = 0; i <= 40; i++) {
  promises.push(new Promise(
    co(function *(resolve, reject) {
      let auction = yield auction.create({
        [...]
      })  // Async creation of model and persisting it in db

      yield bid.create({
        auction: auction.id
        [...]
      })
    )
    resolve()
  ))
}
yield invoicePromises

Answer 1

不需要调用 new Promise（而且它不起作用，因为您从不调用 resolve 或 reject）。省略那部分，co()已经returns一个承诺：

let promises = [];
for (let i = 0; i <= 40; i++) {
  promises.push( co(function *() {
    let auction = yield auction.create({
      [...]
    });  // Async creation of model and persisting it in db
    yield bid.create({
      auction: auction.id
      [...]
    });
  ));
}
yield invoicePromises;

如果您不想使用内部生成器，您也可以使用简单的承诺进行链接：

let promises = [];
for (let i = 0; i <= 40; i++) {
  promises.push(
    auction.create({
      [...]
    }).then(auction =>
      bid.create({
        auction: auction.id
        [...]
      });
    )
  );
}
yield Promise.all(invoicePromises);

并行执行包含共同包装生成器的 Promise

Parallelize execution of Promise containing co wrapped generator

javascript

node.js

co