В чем разница между spawn и fork?

Разница между spawn и fork

Оба метода из модуля child_process запускают отдельные процессы, но предназначены для разных сценариев и имеют разные API.

spawn

spawn — это базовая функция для запуска любой внешней программы (не обязательно Node.js).

const { spawn } = require('child_process');

// Запуск ls команды
const ls = spawn('ls', ['-la', '/home']);

// Слушаем stdout
ls.stdout.on('data', (data) => {
  console.log('Output:', data.toString());
});

// Слушаем stderr
ls.stderr.on('data', (data) => {
  console.error('Error:', data.toString());
});

// Слушаем завершение
ls.on('close', (code) => {
  console.log('Process exited with code', code);
});

Характеристики:

• Работает с любыми программами (ls, ffmpeg, python, node и т.д.)
• Streaming API — данные приходят через события
• Не буферизирует весь вывод в памяти (эффективнее для больших объёмов)
• Нет встроенного IPC (Inter-Process Communication)
• Нужно парсить stdout самостоятельно

Когда использовать:

• Запуск внешних программ
• Обработка больших потоков данных
• Когда не нужна двусторонняя коммуникация с процессом

fork

fork — это специализированный метод для запуска Node.js процессов с встроенным IPC.

const { fork } = require('child_process');

// Запуск worker.js в отдельном процессе
const child = fork('./worker.js');

// Отправка сообщения в child
child.send({task: 'compute', data: [1, 2, 3]});

// Получение ответа от child
child.on('message', (result) => {
  console.log('Result from worker:', result);
});

// Обработка ошибок
child.on('error', (err) => {
  console.error('Child error:', err);
});

// Обработка завершения
child.on('exit', (code) => {
  console.log('Child exited with code', code);
});

worker.js:

// В отдельном Node.js процессе
process.on('message', (msg) => {
  console.log('Received task:', msg.task);
  
  // Выполняем работу
  const result = msg.data.reduce((a, b) => a + b, 0);
  
  // Отправляем результат обратно
  process.send({sum: result});
});

Характеристики:

• Только для Node.js процессов
• Встроенный IPC через send/on('message')
• Удобная двусторонняя коммуникация
• Автоматическая сериализация объектов
• Наследует environment и stdio родителя

Когда использовать:

• Запуск Node.js worker-ов
• Тяжелые вычисления в отдельном процессе
• Когда нужна коммуникация между процессами

Сравнительная таблица

Практические примеры

spawn для обработки больших файлов:

const { spawn } = require('child_process');
const fs = require('fs');

// Запуск grep для поиска в большом файле
const grep = spawn('grep', ['error', 'large.log']);
let lineCount = 0;

grep.stdout.on('data', (data) => {
  const lines = data.toString().split('\n');
  lineCount += lines.length;
  console.log(`Found ${lineCount} error lines so far`);
});

grep.on('close', (code) => {
  console.log(`Total errors: ${lineCount}`);
});

fork для CPU-bound работы:

const { fork } = require('child_process');

app.post('/calculate', (req, res) => {
  const worker = fork('./heavy-compute.js');
  const timeout = setTimeout(() => {
    worker.kill();
    res.status(408).send('Timeout');
  }, 30000);
  
  worker.send({numbers: req.body.data});
  
  worker.on('message', (result) => {
    clearTimeout(timeout);
    res.json(result);
    worker.kill();
  });
});

Гибридный подход

В production приложениях часто используют::

• Worker Threads (встроенный в Node.js) вместо fork для compute-heavy задач
• fork для отдельных воркер-процессов
• spawn для интеграции с внешними инструментами

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

const worker = new Worker('./compute.js');
worker.on('message', (result) => console.log(result));
worker.postMessage({data: [1, 2, 3]});

Вывод: Используй spawn для внешних программ и потокового обработки данных. Используй fork для запуска Node.js воркеров с двусторонней коммуникацией. Для compute-heavy задач рассмотри Worker Threads как современную альтернативу.