并行执行包含 co 包装的生成器的 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() 已经返回了一个承诺：

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;

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

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