Question

async 不具有处理并行流的功能，其中可以找到 each() ， map() ， filter() ， reject() ， detect() ， some() ， every() ， concat() ， parallel() ， applyEach() 和 times() 。它们遵循与我们已经看到的用于顺序执行的功能相同的逻辑，区别在于所提供的任务是并行执行的。

为了证明这一点，我们可以尝试应用上述功能之一来实现我们的 Web 爬虫 应用程序的第三版，即使用无限制的并行流程来执行下载。

如果我们记住我们之前使用的代码来实现 spiderLinks() 函数的顺序版本，那么调整它使其并行工作就比较简单：

function spiderLinks(currentUrl, body, nesting, callback) {
  // ...
  async.each(links, (link, callback) => {
    spider(link, nesting - 1, callback);
  }, callback);
}

这个函数与我们用于顺序下载的功能完全相同，但是使用的是 async.each() 而非 async.eachSeries() 。这清楚地表明了使用库（例如 async ）抽象异步流的功能。代码不再绑定到特定的执行流程了，没有专门为此写的代码。大多数只是应用逻辑。