Node.js ワーカースレッドによる並列処理の解放-jsチュートリアル-php.cn

Node.js ワーカースレッドによる並列処理の解放

Barbara Streisand

リリース： 2024-09-21 06:33:07

オリジナル

848 人が閲覧しました

Unleashing Parallel Processing with Node.js Worker Threads

ワーカースレッドにより、Node.js での真の並列処理が可能になり、CPU を集中的に使用するタスクに最適です。さあ、飛び込みましょう。

なぜワーカースレッドなのか?

JavaScript コードの並列実行
共有メモリ機能
CPU バウンドの操作に最適

基本的な使い方

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

if (isMainThread) {
  const worker = new Worker(__filename);
  worker.on('message', (msg) => console.log('From worker:', msg));
  worker.postMessage('Hello, Worker!');
} else {
  parentPort.on('message', (msg) => {
    console.log('From main:', msg);
    parentPort.postMessage('Hello, Main!');
  });
}

ログイン後にコピー

データの受け渡し

構造化クローンアルゴリズム (デフォルト)
転送可能なオブジェクト
ゼロコピー転送用の SharedArrayBuffer

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

const worker = new Worker('./worker.js');

const sharedBuffer = new SharedArrayBuffer(4);
const arr = new Int32Array(sharedBuffer);
arr[0] = 123;

worker.postMessage({ sharedBuffer });

ログイン後にコピー

ワーカープール

const { StaticPool } = require('node-worker-threads-pool');

const pool = new StaticPool({
  size: 4,
  task: (n) => n * 2
});

async function runTasks() {
  const results = await Promise.all([
    pool.exec(10),
    pool.exec(20),
    pool.exec(30)
  ]);
  console.log(results); // [20, 40, 60]
}

runTasks().catch(console.error);

ログイン後にコピー