Node中如何暂停/停止已启动执行的任务？

首先明确：Node.js没有原生的强制终止正在执行函数的能力（尤其是同步函数），但可以通过任务设计层面的控制来实现停止/暂停功能，以下是针对不同场景的具体实现方案：

一、异步任务的停止（最常用场景） #

Node.js中绝大多数耗时任务都是异步的（如IO操作、定时器、网络请求），这类任务可以通过以下方式优雅终止：

1. 使用AbortController（现代推荐方案） #

对于支持AbortSignal的API（Node.js 15+的setTimeout、fetch、文件流等），可以用AbortController发送终止信号，任务内部监听信号并主动中断流程：

const readline = require('readline');
const ac = new AbortController();
const { signal } = ac;

// 模拟异步任务
async function longRunningTask(param, signal) {
  // 监听终止信号
  signal.addEventListener('abort', () => {
    console.log('任务已收到终止信号，开始清理资源');
    // 这里可以执行资源清理：关闭文件、终止网络请求等
  });

  for (let i = 0; i < 10; i++) {
    if (signal.aborted) break; // 检查信号，终止循环
    await new Promise(resolve => setTimeout(resolve, 1000));
    console.log(`任务执行中：${i+1}/10`);
  }
}

// 处理用户输入
const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout
});

rl.question('输入任务参数（输入stop终止任务）：', (input) => {
  if (input.toLowerCase() === 'stop') {
    ac.abort();
    rl.close();
    return;
  }
  longRunningTask(input, signal);
});

// 监听后续输入终止任务
rl.on('line', (input) => {
  if (input.toLowerCase() === 'stop') {
    ac.abort();
    console.log('已发送任务终止信号');
    rl.close();
  }
});

2. 自定义状态标记 #

对于不支持AbortController的旧版API或自定义异步函数，可以用共享状态变量控制任务流程：

let isTaskCancelled = false;

async function customAsyncTask(param) {
  for (let i = 0; i < 10; i++) {
    if (isTaskCancelled) {
      console.log('任务已终止');
      return;
    }
    await new Promise(resolve => setTimeout(resolve, 1000));
    console.log(`任务进度：${i+1}/10`);
  }
}

// 用户输入处理
const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout
});

rl.question('输入参数启动任务：', (param) => {
  customAsyncTask(param);
});

rl.on('line', (input) => {
  if (input.toLowerCase() === 'stop') {
    isTaskCancelled = true;
    rl.close();
  }
});

注意：这种方式需要任务内部定期检查状态，无法终止已经在执行的异步操作（如已发出的网络请求），只能中断后续流程。

二、同步任务的终止（谨慎处理） #

同步任务会阻塞Node.js的事件循环，无法通过常规方式中断，推荐用以下方案：

使用Worker线程隔离同步任务 #

把耗时同步任务放到独立的Worker线程中，通过worker.terminate()直接终止线程，不会阻塞主线程：

// 主线程代码
const { Worker } = require('worker_threads');
const readline = require('readline');

const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout
});

rl.question('输入参数启动同步任务：', (param) => {
  const worker = new Worker('./sync-task.js', { workerData: param });

  // 接收Worker的进度消息
  worker.on('message', (msg) => {
    console.log(msg);
  });

  // 监听停止指令
  rl.on('line', (input) => {
    if (input.toLowerCase() === 'stop') {
      worker.terminate();
      console.log('同步任务已终止');
      rl.close();
    }
  });
});

sync-task.js（Worker线程代码）：

const { parentPort, workerData } = require('worker_threads');

function heavySyncTask(param) {
  for (let i = 0; i < 1e8; i++) {
    if (i % 1e7 === 0) {
      parentPort.postMessage(`同步任务进度：${(i/1e8)*100}%`);
    }
  }
  parentPort.postMessage('任务完成');
}

heavySyncTask(workerData);

三、任务的暂停与恢复 #

如果需要实现暂停后可恢复的功能，需要用状态标记+异步等待的方式：

let isPaused = false;

async function pausableTask(param) {
  for (let i = 0; i < 10; i++) {
    // 暂停时进入循环等待
    while (isPaused) {
      await new Promise(resolve => setTimeout(resolve, 100));
    }

    await new Promise(resolve => setTimeout(resolve, 1000));
    console.log(`任务进度：${i+1}/10`);
  }
}

// 用户输入处理
const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout
});

rl.question('输入参数启动任务：', (param) => {
  pausableTask(param);
});

rl.on('line', (input) => {
  switch(input.toLowerCase()) {
    case 'pause':
      isPaused = true;
      console.log('任务已暂停');
      break;
    case 'resume':
      isPaused = false;
      console.log('任务已恢复');
      break;
    case 'stop':
      isPaused = false;
      console.log('任务已终止');
      rl.close();
      break;
  }
});

内容的提问来源于stack exchange，提问作者Webby