NodeJS：异步函数仍然暂停主函数[重复]

Question

我正在尝试让一个函数调用一些代码，同时让我的主函数继续运行而不必等待它。

到目前为止它还没有工作：

function doSomething() {
  return new Promise((resolve, reject) => {
    if(1) {
        console.log("doing something");
        for(let i = 0; i < 10000; i++) {
            for(let j = 0; j < 10000; j++) {
                for(let k = 0; k < 100; k++) {
                 // Do something for a long time to check if async is working
                }
            }
        }
        console.log("finished doing something");
        resolve( {"dummydata": 10} );
    }
    else {
        reject("error!");
    }
  })
}

function main() {
    doSomething()
    .then(data => console.log(data))
    .catch(err => console.error(err))

    console.log("this should print before doSomething() is finished");
}

main();

这是输出：

做某事

做完一件事

这应该在 doSomething() 完成之前打印

{ 虚拟数据：10 }

为什么我的程序在等待 doSomething()？我希望它并行/异步运行。我还尝试将 main() 设为异步函数，与 doSomething() 相同，但这不起作用。

Answer 1

JavaScript 仍然是单线程的。如果你有一段昂贵的代码，比如你的嵌套循环，并且你没有在循环内await，那么当循环迭代时，你环境中的所有其他 JavaScript 处理都将被阻塞 - 控制流只会在所有循环中返回同步代码已完成。

放在 Promise 构造函数回调顶层的代码会立即运行 - 执行 return new Promise 不会使代码放在单独的线程或类似的东西上。

虽然您可以排队任务，让它在延迟后启动，并让主脚本继续它需要做的任何事情：

function main() {
  setTimeout(doSomething, 2000);
  // more code

要真正并行运行它，您需要使用child_process。将脚本的昂贵部分放入自己的文件中，并让 child_process 通过.fork 调用它。

Answer 2

你可以使用worker_threads：https://nodejs.org/api/worker_threads.html#worker-threads

const { Worker } = require("worker_threads");

const worker = new Worker(
  `
const { parentPort } = require('worker_threads');

parentPort.postMessage("doing something");
  for (let i = 0; i < 10000; i++) {
    for (let j = 0; j < 10000; j++) {
      for (let k = 0; k < 100; k++) {
        // Do something for a long time to check if async is working
      }
    }
  }
  parentPort.postMessage("finished doing something");
  parentPort.postMessage({ dummydata: 10 });

`,
  { eval: true }
);
worker.on("message", (message) => console.log(message));

console.log("this should print before doSomething() is finished");

这只是一个sn-p。可以和worker等交换数据……