node.js 中的 async/await 理解

Question

已经阅读了大量的文章和文档，但是这个主题对我来说仍然不够清楚。引用一个答案https://stackoverflow.com/a/46004461/630169：

只要 async/await 中包含的代码是非阻塞的 它不会阻塞，例如，数据库调用、网络调用、文件系统调用。

但是如果包含在 async/await 中的代码是阻塞的，那么它会 阻塞整个 Node.js 进程，例如无限循环、CPU 图像处理等密集型任务。

但是，Understanding the node.js event loop 说：

当然，后端有DB的线程和进程 访问和进程执行。

在 C# 中，编写标记为 async 的函数并使用 await 调用就足够了，因此 .Net 将其放在另一个线程中。然而，它让我感到困惑的是，在 Node.js 中以不同方式组织的东西，async/await 函数仍然会阻塞主线程。

所以问题是：如何在 node.js 中编写（组织）任意async/await 函数以确保它将在单独的线程或进程中异步运行？有好的代码示例吗？一些npm 模块？让它没有比 C# 变体更棘手也很好。谢谢！

一些使其成为非阻塞的函数示例，例如，如果我想要同步 DB 调用来实现异步（非阻塞）：

var Database = require('better-sqlite3');

var db = new Database('./my_db.sqlite');

async function DBRequest() {
    var row = db.prepare("SELECT * FROM table");
    return row;
};

注意： better-sqlite3 — 同步模块。

Answer 1

这里有一些示例代码。决定提供它是一个值得的练习。

您可以编写长时间运行的阻塞代码，以便将执行时间留给其他函数

var array = new Array(100);
function processNext(){
    if (array.length === 0) return;
    var item = array.shift(); // gets first item from array and removes it.
    process(item); // 0.5 seconds of blocking time
    setTimeout(processNext ,500); // wait 0.5 seconds and then process the next one
    // during this waiting time, other code will run on your server.
}

processNext();

诚然，我是一个新手，由于我不知道的原因，这可能是一个非常糟糕的主意。

Answer 2

您真的受制于您在此处使用的库 - 如果代码是同步的且不受 I/O 限制，那么您实际上无法在 Node 进程中执行太多其他操作来使其异步。

您唯一真正的选择是将代码移到它自己的进程中，从而使其受 I/O 限制，这样您的应用程序可以等待它而不阻塞它自己的线程。

Answer 3

我的兴趣不是没有的——在我之前people asked 以及on stackoverflow（和here）的类似问题：

但时间长、受 CPU 限制的任务是什么？

当任务在手时，如何避免阻塞事件循环 不受 I/O 限制，并且持续时间超过几分之一毫秒？ 你根本不能，因为没有办法......好吧，没有 在threads_a_gogo之前。

为了解决这些问题，他们已经创建了一堆模块，其中一些模块，例如 threads，在浏览器和 Node.js 中都可以工作：

• threads
• Threads à gogo
• nPool
• threadpool-js
• threadpool
• 等

如果有人可以将async/await 附加到他们或提供很好的例子，那就太好了。

顺便说一句，here's a comrade tests 在 Threads à gogo 上驱动 - 使用线程的结果是 40x faster，而不是使用 Cluster。所以 Node.js 的单线程想法并不总是很好。