Node.JS [ru] | Серверный JavaScript

👩‍💻 Как работает потокобезопасность (thread safety) в Node.js?

Node.js работает в однопоточном режиме, используя цикл событий для обработки асинхронных операций. Однако потокобезопасность становится важной при работе с параллельными задачами или при использовании worker_threads. В таких случаях необходимо обеспечить изоляцию данных между потоками.

➡️ Пример:

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

if (isMainThread) {
  const worker = new Worker(__filename);
  worker.on('message', msg => console.log(`Получено от воркера: ${msg}`));
  worker.postMessage('Привет из основного потока!');
} else {
  parentPort.on('message', msg => {
    console.log(`Получено в воркере: ${msg}`);
    parentPort.postMessage('Привет обратно!');
  });
}

🗣 Потокобезопасность в Node.js обеспечивается изоляцией памяти worker_threads, и при необходимости обмена данными рекомендуется использовать сообщения между потоками для минимизации риска гонок данных.

🖥 Подробнее тут

Please open Telegram to view this post

VIEW IN TELEGRAM

www.tgoop.com/we_use_js/4938

1.5K viewsOct 17 at 12:07

👩‍💻 Как работает потокобезопасность (thread safety) в Node.js?

Node.js работает в однопоточном режиме, используя цикл событий для обработки асинхронных операций. Однако потокобезопасность становится важной при работе с параллельными задачами или при использовании worker_threads. В таких случаях необходимо обеспечить изоляцию данных между потоками.

➡️ Пример:

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

if (isMainThread) {
  const worker = new Worker(__filename);
  worker.on('message', msg => console.log(`Получено от воркера: ${msg}`));
  worker.postMessage('Привет из основного потока!');
} else {
  parentPort.on('message', msg => {
    console.log(`Получено в воркере: ${msg}`);
    parentPort.postMessage('Привет обратно!');
  });
}

🗣 Потокобезопасность в Node.js обеспечивается изоляцией памяти worker_threads, и при необходимости обмена данными рекомендуется использовать сообщения между потоками для минимизации риска гонок данных.