Nodejs里如何处理比较耗时的任务

13 楼正解。同步方法会停止事件循环，直到操作完成。所以作为一个应用，任意 io 操作（包括网络，文件读写）都必须用异步方式。

我就假设你的任务是将一个大的二进制数据转换到另一个大的二进制数据，有两种方法改进

- 用 worker ，类似 nodejs 在其它语言的子线程，这样你的主线程就不受到干扰
- 将你的处理函数改成 async 的，内部将大任务按数据量分成批量小任务，每个小任务用 await new Promise(r=>setTimeout®) 隔开，这样你的大任务就不会同步阻塞

业务上做成异步化，就是用户提交请求之后，服务器记录这个请求到消息队列，然后立即返回给用户处理中的信息，用户此时可以去干别的，过一会可以在特定界面查看人物结果。

服务上就是一个负责与用户交互的服务，一个消息队列用于记录任务，一个负责从队列里读出任务并进行处理的集群服务。集群服务处理完每个任务就会把结果塞到数据库里供交互服务查询，或者重新塞到另一个消息队列里让下游的服务消费。

在Node.js中处理比较耗时的任务，通常不会直接在事件循环中同步执行，因为这会导致阻塞，影响服务器的性能和响应能力。有几种常见的方法可以处理耗时任务：

1. 使用回调函数（Callbacks）： 虽然回调函数不是最优雅的方法，但它是一种基本的异步编程技术。

2. Promise： Promise提供了一种更清晰的方式来处理异步操作，避免了回调地狱。

   function longRunningTask() {
       return new Promise((resolve, reject) => {
           setTimeout(() => {
               resolve("Task Completed");
           }, 5000); // 模拟耗时任务
       });
   }
   
   longRunningTask().then(result => {
       console.log(result);
   }).catch(error => {
       console.error(error);
   });

3. Async/Await： Async/Await基于Promise，但提供了更同步的代码风格，使得异步代码更易于阅读和理解。

   async function runTask() {
       try {
           const result = await longRunningTask();
           console.log(result);
       } catch (error) {
           console.error(error);
       }
   }
   
   runTask();

4. 使用子进程（Child Processes）： 对于CPU密集型任务，可以考虑使用child_process模块来创建子进程，将任务卸载到子进程中执行。

   const { exec } = require('child_process');
   exec('your-cpu-intensive-task', (error, stdout, stderr) => {
       if (error) {
           console.error(`exec error: ${error}`);
           return;
       }
       console.log(`stdout: ${stdout}`);
       console.error(`stderr: ${stderr}`);
   });

选择哪种方法取决于你的具体需求和代码风格偏好。