将 async/await 与 setTimeout 函数相结合

Question

我正在尝试从网站下载文件，并希望使用 setTimeout 在每个请求之间暂停代码 1 秒。

我有一个 stockFile 函数，它循环遍历一组 url（path 是我在磁盘上存储文件的位置）。这是我的代码（版本 A）：

async function stockFiles(urls, path) {
  _.map(urls, async (elem) => {
    await timeOut(1000);
    const writableStream = await _createWriteStream(path);
    await _getFile(elem, writableStream);
  });
}

function timeOut(ms) {
  return new Promise((fulfill) => {
    setTimeout(fulfill, ms);
  });
}

编辑：版本 B：

async function stockFiles(urls, path) {
  _.map(urls, async (elem) => {
    const writableStream = await _createWriteStream(path);
    await _getFile(elem, writableStream);
    await timeOut(1000);
  });
}

function timeOut(ms) {
  return new Promise((fulfill) => {
    setTimeout(fulfill, ms);
  });
}

问题：当我调用 stockFiles（版本 A）时，它会在发出请求之前暂停，但似乎我同时在磁盘上收到所有文件。我真正想要的是我的代码在每个请求之间暂停，因此每个文件接收之间存在延迟。

编辑：当我调用 stockFiles（版本 B）时，它根本不会暂停执行，并且我会同时收到所有文件。

/**************** helpers functions **************/

function _createWriteStream(path) {
  return new Promise((fulfill, reject) => {
    fs.createWriteStream(path, (err, data) => {
      if (err) {
        reject(err);
      }
      fulfill(data);
    });
  });
}

// I use superagent package to make the request
async function _getFile(url, writableStream) {
  await request
    .get(url)
    .buffer(true).parse(request.parse.image)
    .pipe(writableStream);
}

Answer 1

问题是您同时启动所有请求，然后它们都在等待 1000 毫秒，然后它们都在执行。听起来你已经明白了。您需要做的是将它们排队，以便每个仅在前一个完成后才开始。

尝试将您的 stockFiles 函数更改为类似这样的功能：

async function stockFiles(urls, path) {
  for (let url of urls) {
    const writableStream = await _createWriteStream(path);
    await _getFile(elem, writableStream);
    await timeOut(1000);
  }
}

这是一些完整的示例代码。我已经对其进行了测试，并观察到循环每秒只运行一次迭代（通过观察 console.logs 可以看出）。

function timeOut(ms) {
  return new Promise((fulfill) => {
    setTimeout(fulfill, ms);
  });
}

async function stockFiles(urls, path) {
  for (let url of urls) {
    console.log(url);
    await timeOut(1000);
  }
}

let urls = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];
stockFiles(urls);