Node.js多Worker线程并发写同一文件为何未出现内容混乱？

核心原因一：操作系统追加模式的原子性保障 #

你创建写入流时指定了flags: 'a'，这个参数对应操作系统的O_APPEND文件打开模式。内核会强制保证每个write系统调用的原子性：当多个线程/进程同时向该文件写入时，每个write调用的内容会被完整追加到文件末尾，不会被其他写入操作打断或拆分。

简单说，内核处理O_APPEND模式的写入时，会自动完成「将文件指针移到末尾→执行写入」的原子操作，不会被其他线程抢占，自然不会出现内容交错混乱的情况。

核心原因二：Worker线程的独立流并未打破原子性规则 #

你可能误以为Worker线程共享了主线程的writeStream，但实际上Node.js的Worker线程是完全独立的执行上下文——每个Worker都会重新执行整个脚本，所以每个Worker都会创建属于自己的fs.createWriteStream实例。不过即使多个独立流指向同一个文件，只要打开时用了O_APPEND，操作系统的原子性保障依然生效，每个流的写入内容都能完整追加。

什么时候才会出现写入冲突？ #

只有满足以下条件时，才可能出现内容混乱：

• 写入的内容超过了操作系统支持的原子写入大小（不同系统限制不同，比如部分Linux系统是4KB，Windows限制更大）
• 未使用O_APPEND模式，而是手动定位文件指针后写入（比如用fs.write时自行指定写入位置）
• 在多线程中执行大内容的同步写入（同步写入本身会阻塞线程，但依然可能因指针偏移导致出错）

你的代码可以优化的点 #

当前代码每个Worker都创建独立的写入流，会带来额外的资源开销。可以改成主线程统一创建写入流，Worker通过消息传递把要写入的内容发给主线程，由主线程统一写入，这样能减少文件句柄占用，也更可控：

'use strict';

const {
  Worker, isMainThread, parentPort, workerData,
} = require('node:worker_threads');
const fs = require('node:fs');

const outputFile = './data.txt';

if (isMainThread) {
  const writeStream = fs.createWriteStream(outputFile, { flags: 'a' });
  const handleWorkerMessage = (data) => {
    writeStream.write(data);
  };

  for (let i = 0; i < 10; i++) {
    const workerName = `worker_${i}`;
    const worker = new Worker(__filename, { workerData: workerName });
    worker.on('message', handleWorkerMessage);
    writeStream.write(`[worker_created]${workerName}\r\n`);
  }
} else {
  const workerName = workerData;
  parentPort.postMessage(`[worker_started]${workerName}\r\n`);
  const start = Date.now();
  while (start + 5000 > Date.now()) {
    parentPort.postMessage(`[worker_write]${workerName} ${Date.now()}\r\n`);
  }
  parentPort.postMessage(`[worker_finished]${workerName}\r\n`);
}

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