並列処理にworker_threadsマルチスレッドを使用したNode.jsの簡単な分析

Node.js を並列処理に使用するにはどうすればよいですか?次の記事では、Node マルチスレッドを利用して並列処理を行う方法を紹介しますので、ご参考になれば幸いです。

シングルスレッドの NodeJS がマルチスレッド バックエンドとどのように競合できるのかを理解できない人は多いようです。

その理由を知るには、Nodejs がシングルスレッドであることの実際の意味を理解する必要があります。

JavaScript 自体は、もともとフォームの検証や応答の作成などの単純な処理を実行するために作成されました。Node.js の作成者 Ryan Dahl が JavaScript でサーバーサイド コードを記述することが一般的なオプションになったのは 2009 年になってからです。 。

マルチスレッドをサポートするサーバーサイド言語には、スレッド間や他のスレッド指向の機能を同期するためのさまざまな構造と構造があります。

これらをサポートするということは、JavaScript が言語全体を変更する必要があることを意味しますが、これは JavaScript の作成者の考えにも反します。したがって、純粋な JavaScript でマルチスレッドをサポートするために、Dahl は回避策を作成する必要がありました。見てみましょう！

---

Node.js はどのように機能しますか?

Node.js は 2 種類のスレッドを使用します。イベント ループによって処理されるメイン スレッドと、ワーカー スレッドのプール内のいくつかのセカンダリ スレッドです。

イベント ループノンブロッキング I/O 操作を処理するための Node.js メカニズム - JavaScript はシングルスレッドですが、可能な場合は操作をシステムにオフロードします。 カーネルに移動します。 JavaScript 操作がスレッドをブロックすると、イベント ループもブロックされます。

ワーク プールは、個別のスレッドを生成して処理し、タスクを同期的に実行して結果をイベント ループに返す実行モデルです。次に、イベント ループはその結果を使用して、提供されたコールバックを実行します。

基本的に、ワーカー プールは非同期 I/O 操作、つまり主にシステム ディスクおよびネットワークとの対話を処理します。 fs (I/O 負荷が高い) や crypto (CPU 負荷が高い) など、一部のモジュールは、すぐに使用できるワーカー プールを使用します。ワーカー プールは libuv で実装されており、ノードが JavaScript と C の間で内部的にデータを転送する必要がある場合、わずかではありますが、ほとんど無視できるほどの遅延が発生します。

イベント ループとワーク プールの意味を理解した後、次のコードを見てみましょう:

上記のコードでは、待つ必要はありません。イベントの場合は同期的に。ファイルを読み取るタスクをワーカー プールに委任し、結果を使用して提供された関数を呼び出します。ワーカー プールには独自のスレッドがあるため、ファイルの読み取り中もイベント ループは通常どおり実行を続けることができます。

---

ご紹介します: worker_threads

Node.js 10.5.0 のリリースにより、worker_threads が登場しました。 JavaScript での単純なマルチスレッド アプリケーションの作成をサポートします。

worker_threads は、nodejs モジュール パッケージです。スレッド ワーカーは、別のスレッドで生成されるコードの一部 (通常はファイルから取得されます) です。

スレッド ワーカー、ワーカー、スレッドという用語は、多くの場合同じ意味で使用されることに注意することが重要です。それらはすべて同じものを指します。

#Node.js のワーカー スレッドは、負荷の高い JavaScript タスクを実行するのに役立ちます。スレッドの助けを借りて、ワーカーは JavaScript コードを簡単に並列実行できるため、より高速かつ効率的に実行できます。メインスレッドを妨げることなく、重いタスクを完了できます。

ワーカー スレッドは、古いバージョンの Node.js では導入されませんでした。したがって、始めるにはまず Node.js を更新します。

次に、スレッドを実装するための 2 つのファイルを次のように作成します。

ファイル名:worker.js

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

console.log(`Write-up on how ${workerData} wants to chill with the big boys`);

parentPort.postMessage({ filename: workerData, status: 'Done' });

ファイル名:index.js

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

const runSerice = (workerData) => {
  return new Promise((resolve, reject) => {
    const worker = new Worker('./worker.js', { workerData });
    worker.on('message', resolve);
    worker.on('error', reject);
    worker.on('exit', (code) => {
      if (code !== 0)
        reject(new Error(`Worker Thread stopped with exit code ${code}`));
    });
  });
};
const run = async () => {
  const result = await runSerice('Tunde Ednut');
  console.log(result);
};

run().catch((err) => console.error(err));

出力:

ノード関連の知識の詳細については、次を参照してください: nodejs チュートリアル !

以上が並列処理にworker_threadsマルチスレッドを使用したNode.jsの簡単な分析の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。