{"id":339296,"date":"2022-10-04T15:00:22","date_gmt":"2022-10-04T15:00:22","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=339296"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=339296","title":{"rendered":"\u041f\u0440\u0438\u0440\u0443\u0447\u0430\u0435\u043c \u043c\u043d\u043e\u0433\u043e\u043f\u043e\u0442\u043e\u0447\u043d\u043e\u0441\u0442\u044c \u0432 Node.js (\u0447\u0430\u0441\u0442\u044c 4: \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440 \u043f\u0440\u043e\u0442\u0438\u0432 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430)<\/span>"},"content":{"rendered":"
<\/div>\n
\n
\n
\n
\n
<\/figcaption><\/figure>\n

\u0412\u00a0\u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u0439 \u0447\u0430\u0441\u0442\u0438<\/a>\u00a0\u043c\u044b \u043d\u0430\u0443\u0447\u0438\u043b\u0438\u0441\u044c \u044d\u0444\u0444\u0435\u043a\u0442\u0438\u0432\u043d\u043e \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u043c \u043f\u043e\u0442\u043e\u043a\u0430\u043c \u0438\u0437 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0433\u043e \u0447\u0435\u0440\u0435\u0437 \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u0443\u044e \u043f\u0430\u043c\u044f\u0442\u044c, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f Atomics<\/code>-\u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 \u0438 \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438.<\/p>\n

\u041d\u043e \u043c\u044b \u0440\u0430\u0441\u0441\u043c\u0430\u0442\u0440\u0438\u0432\u0430\u043b\u0438 \u0432\u0441\u0435-\u0442\u0430\u043a\u0438 \u0438\u0434\u0435\u0430\u043b\u044c\u043d\u0443\u044e \u0441\u0438\u0442\u0443\u0430\u0446\u0438\u044e, \u043a\u043e\u0433\u0434\u0430 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u043f\u043e\u0442\u043e\u043a \u0431\u043e\u043b\u044c\u0448\u0435 \u043d\u0438\u0447\u0435\u043c \u043d\u0435 \u0437\u0430\u043d\u0438\u043c\u0430\u043b\u0441\u044f<\/strong>, \u043a\u0440\u043e\u043c\u0435 \u043e\u0431\u043c\u0435\u043d\u0430 \u0441 «\u043f\u043e\u0434\u0447\u0438\u043d\u0435\u043d\u043d\u044b\u043c\u0438» \u0443\u0436\u0435 \u0437\u0430\u0440\u0430\u043d\u0435\u0435 \u0433\u043e\u0442\u043e\u0432\u044b\u043c\u0438 \u0434\u0430\u043d\u043d\u044b\u043c\u0438. \u0412 \u0440\u0435\u0430\u043b\u044c\u043d\u044b\u0445 \u0436\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f\u0445 \u0442\u0430\u043a\u043e\u0435 \u0432\u0441\u0442\u0440\u0435\u0447\u0430\u0435\u0442\u0441\u044f \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u0440\u0435\u0434\u043a\u043e — \u043e\u0431\u044b\u0447\u043d\u043e \u044d\u0442\u0438 \u0441\u0430\u043c\u044b\u0435 \u0434\u0430\u043d\u043d\u044b\u0435 \u043f\u0440\u0438\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0433\u043e\u0442\u043e\u0432\u0438\u0442\u044c \u043d\u0435\u043f\u043e\u0441\u0440\u0435\u0434\u0441\u0442\u0432\u0435\u043d\u043d\u043e \u043f\u0435\u0440\u0435\u0434 \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0435\u0439. \u0418, \u0431\u044b\u0432\u0430\u0435\u0442, \u0432 \u044d\u0442\u043e\u043c \u0443\u0447\u0430\u0441\u0442\u0432\u0443\u0435\u0442 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0435\u043d\u043d\u0430\u044f \u0434\u043e\u043b\u044f \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430<\/strong>, \u0447\u0442\u043e \u0434\u043b\u044f JavaScript \u043a\u0440\u0430\u0439\u043d\u0435 \u043d\u0435\u043f\u0440\u0438\u044f\u0442\u043d\u043e, \u043d\u043e \u0438\u043d\u043e\u0433\u0434\u0430 \u043d\u0435\u0438\u0437\u0431\u0435\u0436\u043d\u043e — \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043f\u0440\u0438 \u0432\u044b\u0447\u0438\u0441\u043b\u0435\u043d\u0438\u0438 \u0440\u0435\u0433\u0443\u043b\u044f\u0440\u043d\u044b\u0445 \u0432\u044b\u0440\u0430\u0436\u0435\u043d\u0438\u0439.<\/p>\n

\u0414\u0430\u0432\u0430\u0439\u0442\u0435 \u043e\u0446\u0435\u043d\u0438\u043c, \u043d\u0430\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438 «\u0440\u043e\u043d\u044f\u044e\u0442» \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u043d\u0430\u0448\u0435\u0433\u043e \u0442\u0435\u0441\u0442\u043e\u0432\u043e\u0433\u043e \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f. \u0418 \u0443\u0437\u043d\u0430\u0435\u043c, \u043a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0432 \u0440\u0430\u0437\u044b \u0443\u043b\u0443\u0447\u0448\u0438\u0442\u044c \u0435\u0435, «\u0441\u043a\u0440\u0435\u0441\u0442\u0438\u0432 \u0443\u0436\u0430 \u0441 \u0435\u0436\u043e\u043c», \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f \u0432\u044b\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0439 \u043f\u043e\u0442\u043e\u043a-\u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440<\/strong> \u0438\u0437 \u043f\u043e\u0437\u0430\u043f\u0440\u043e\u0448\u043b\u043e\u0439 \u0447\u0430\u0441\u0442\u0438 \u0441\u0442\u0430\u0442\u044c\u0438<\/a> \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u043d\u043e \u0441 \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u044c\u044e.<\/p>\n

\u0414\u043e\u0431\u0430\u0432\u0438\u043c \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0441\u0442\u0438<\/h2>\n

\u0412\u043e\u0437\u044c\u043c\u0435\u043c \u0442\u043e\u0442 \u0436\u0435 \u0441\u0430\u043c\u044b\u0439 \u0442\u0435\u0441\u0442 \u0438\u0437 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0435\u0439 \u0447\u0430\u0441\u0442\u0438<\/a> \u043f\u0440\u043e \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u0443\u044e \u043f\u0430\u043c\u044f\u0442\u044c \u0438 \u0432\u043c\u0435\u0441\u0442\u043e \u043c\u0430\u0441\u0441\u0438\u0432\u0430 \u0441\u043e\u0445\u0440\u0430\u043d\u0438\u043c \u0432\u0441\u0435 «\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f» \u0432\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0439 \u043a\u0430\u0442\u0430\u043b\u043e\u0433:<\/p>\n

  const fs = require('node:fs');   const {tmpdir} = require('node:os');   const {sep} = require('node:path');    \/\/ \u0441\u043e\u0437\u0434\u0430\u0435\u043c \u0432\u0440\u0435\u043c\u0435\u043d\u043d\u0443\u044e \u043f\u0430\u043f\u043a\u0443 \u0438 \u0432 \u043d\u0435\u0439 \u0444\u0430\u0439\u043b\u044b \u0441\u043e \u0432\u0441\u0435\u043c\u0438 \"\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\u043c\u0438\"   const dir = fs.mkdtempSync(tmpdir() + sep);   messages.forEach((data, i) => {     const fn = i.toString(16).padStart(3, '0');     fs.writeFileSync(dir + sep + fn, data);   });<\/code><\/pre>\n
\u0410 \u0443\u0436\u0435 \u0432 \u0445\u043e\u0434\u0435 \u0442\u0435\u0441\u0442\u0430 \u0431\u0443\u0434\u0435\u043c \u0438\u0445 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e<\/strong> \u0432\u044b\u0447\u0438\u0442\u044b\u0432\u0430\u0442\u044c \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e readFileSync<\/code>, \u043d\u0430\u043c\u0435\u0440\u0435\u043d\u043d\u043e «\u043f\u0440\u0438\u0442\u043e\u0440\u043c\u0430\u0436\u0438\u0432\u0430\u044f» EventLoop \u0432 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u043c \u043f\u043e\u0442\u043e\u043a\u0435 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f:<\/p>\n
      \/\/ \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u0441\u043f\u0438\u0441\u043e\u043a \u0432\u0441\u0435\u0445 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432 \u043f\u0430\u043f\u043a\u0435       const fns = fs.readdirSync(dir)         .sort()         .map(fn => dir + sep + fn);        remain = fns.length;       tsh = hrtime();       tfs = 0n; \/\/ \u0434\u043b\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0445 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0439        fns.forEach((fn, id) => {         const ts = hrtime();         const data = fs.readFileSync(fn); \/\/ \u0442\u044f\u0436\u0435\u043b\u044b\u0439 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434         tfs += hrtime() - ts;             \/\/ ... \u0438 \u0435\u0433\u043e \u043f\u0440\u043e\u0434\u043e\u043b\u0436\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c         pool.postMessage({id, data});       });<\/code><\/pre>\n
\n\u041c\u0438\u0440\u0438\u043c\u0441\u044f \u0441 \u043d\u0435\u0441\u0442\u0430\u0431\u0438\u043b\u044c\u043d\u043e\u0441\u0442\u044c\u044e \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u0447\u0442\u0435\u043d\u0438\u044f \u0441 \u0434\u0438\u0441\u043a\u0430<\/summary>\n
\n
\u041f\u0440\u0438 \u043f\u0440\u043e\u0432\u0435\u0434\u0435\u043d\u0438\u0438 \u043f\u043e\u0434\u043e\u0431\u043d\u043e\u0433\u043e \u0442\u0435\u0441\u0442\u0430 \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u0441\u0438\u043b\u044c\u043d\u043e \u043c\u043e\u0436\u0435\u0442 \u0432\u043b\u0438\u044f\u0442\u044c \u0430\u0441\u043f\u0435\u043a\u0442 \u043a\u044d\u0448\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f<\/strong> \u0447\u0442\u0435\u043d\u0438\u044f.<\/p>\n
\u0422\u043e \u0435\u0441\u0442\u044c \u0435\u0441\u043b\u0438 \u043d\u0430\u043c «\u043f\u043e\u0432\u0435\u0437\u043b\u043e», \u0438 \u0434\u0430\u043d\u043d\u044b\u0435 \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u043e\u0433\u043e \u0444\u0430\u0439\u043b\u0430 \u041e\u0421 \u0435\u0449\u0435 \u043d\u0435 \u0443\u0441\u043f\u0435\u043b\u0430 \u0432\u044b\u0442\u0435\u0441\u043d\u0438\u0442\u044c \u0438 \u0434\u0435\u0440\u0436\u0438\u0442 \u0432 pagecache<\/code>, \u0442\u043e \u0443\u043c\u0435\u043d\u044c\u0448\u0438\u0442\u0441\u044f \u0432\u0440\u0435\u043c\u044f \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0433\u043e \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f<\/strong> \u0434\u043b\u044f \u0432\u0441\u0435 \u0442\u043e\u0433\u043e \u0436\u0435 readSync<\/code> \u0442\u043e\u0433\u043e \u0436\u0435 \u0444\u0430\u0439\u043b\u0430 \u0432 \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u043c \u043f\u0440\u043e\u0433\u043e\u043d\u0435, \u0438 \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u043c\u043e\u0436\u0435\u0442 \u043c\u0435\u043d\u044c\u0448\u0435 \u043f\u043e\u0432\u043b\u0438\u044f\u0442\u044c \u043d\u0430 \u0434\u0435\u0433\u0440\u0430\u0434\u0430\u0446\u0438\u044e \u043e\u0431\u0449\u0435\u0433\u043e \u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u0442\u0435\u0441\u0442\u0430.<\/p>\n<\/p>\n<\/div>\n<\/details>\n
\u0422\u0443\u0442 \u043c\u044b \u0437\u0430\u043c\u0435\u0440\u044f\u0435\u043c \u043a\u0430\u043a \u043e\u0431\u0449\u0435\u0435 \u0432\u0440\u0435\u043c\u044f \u043e\u0442\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0442\u0435\u0441\u0442\u0430, \u0442\u0430\u043a \u0438 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e \u0434\u043b\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0445 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0439. \u0418\u0445 \u0440\u0430\u0437\u043d\u043e\u0441\u0442\u044c \u0434\u0430\u0441\u0442 \u043d\u0430\u043c, \u043a\u043e\u043d\u0435\u0447\u043d\u043e, \u043d\u0435 \u0441\u0430\u043c\u043e \u0432\u0440\u0435\u043c\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 (\u043f\u043e\u043a\u0430 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u043f\u043e\u0442\u043e\u043a \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e \u0447\u0438\u0442\u0430\u0435\u0442, \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u0435-\u0442\u043e \u0440\u0430\u0431\u043e\u0442\u0430\u044e\u0442), \u043d\u043e \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043e\u0446\u0435\u043d\u043a\u0443 \u043e\u0431\u0449\u0435\u0439 \u043f\u043e\u0442\u0435\u0440\u0438 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438.<\/p>\n
\n\u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 \u0438 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b \u0442\u0435\u0441\u0442\u043e\u0432<\/summary>\n
\n
const {   Worker , isMainThread , parentPort , workerData } = require('node:worker_threads');  const {   randomBytes , createHash } = require('node:crypto');  const hrtime = process.hrtime.bigint;  const THREAD_FREE = -1;  const EventEmitter = require('events'); class WorkersPool extends EventEmitter {   #queue;   #workersPool;    constructor({queue, workersPool}) {     super();      this.#queue = queue;     this.#workersPool = [...workersPool];   }    #shareMessage(worker, {id, data}) {     worker.data.set(data, 0);     worker.lock[0] = id;     Atomics.notify(worker.lock, 0, 1);      const lock = Atomics.waitAsync(worker.lock, 0, id);     if (lock.value === 'not-equal') {       this.#onMessage(worker);     }     else {       lock.value.then(result => {         this.#onMessage(worker);       });     }   }    #onMessage(worker) {     const msg = this.#queue.shift();     if (msg) {       this.#shareMessage(worker, msg);     }     else {       this.#workersPool.push(worker);     }   }    postMessage(msg) {     const worker = this.#workersPool.pop();     if (worker) {       this.#shareMessage(worker, msg);     }     else {       this.#queue.push(msg);     }   } }  if (isMainThread) {   const taskSize = 1 << 16;      const tsg = hrtime();   const messages = Array(1 << 12).fill().map(_ => randomBytes(taskSize));    const fs = require('node:fs');   const {tmpdir} = require('node:os');   const {sep} = require('node:path');    \/\/ \u0441\u043e\u0437\u0434\u0430\u0435\u043c \u0432\u0440\u0435\u043c\u0435\u043d\u043d\u0443\u044e \u043f\u0430\u043f\u043a\u0443 \u0438 \u0432 \u043d\u0435\u0439 \u0444\u0430\u0439\u043b\u044b \u0441\u043e \u0432\u0441\u0435\u043c\u0438 \"\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\u043c\u0438\"   const dir = fs.mkdtempSync(tmpdir() + sep);   messages.forEach((data, i) => {     const fn = i.toString(16).padStart(3, '0');     fs.writeFileSync(dir + sep + fn, data);   });   console.log('generated:', Number(hrtime() - tsg)\/1e6 | 0, 'ms');    const hashes = messages.map(() => undefined);   let remain;    const workers = [];   let active = 1;   let tsh;   let tfs;    process     .on('test:start', () => {       hashes.fill();        const Pow2Buffer = require('.\/Pow2Buffer');       pool = new WorkersPool({         queue : new Pow2Buffer(8, 16)       , workersPool : workers.slice(0, active)       });        \/\/ \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u0441\u043f\u0438\u0441\u043e\u043a \u0432\u0441\u0435\u0445 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432 \u043f\u0430\u043f\u043a\u0435       const fns = fs.readdirSync(dir)         .sort()         .map(fn => dir + sep + fn);        remain = fns.length;       tsh = hrtime();       tfs = 0n; \/\/ \u0434\u043b\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0445 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0439        fns.forEach((fn, id) => {         const ts = hrtime();         const data = fs.readFileSync(fn); \/\/ \u0442\u044f\u0436\u0435\u043b\u044b\u0439 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434         tfs += hrtime() - ts;             \/\/ ... \u0438 \u0435\u0433\u043e \u043f\u0440\u043e\u0434\u043e\u043b\u0436\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c         pool.postMessage({id, data});       });     })     .on('test:end', () => {       const duration = hrtime() - tsh;        console.log(         'hashed ' + active.toString().padStart(2) + ':'       , (Number(duration - tfs)\/1e6 | 0).toString().padStart(4)       , 'ms'       , '| fs.read'       , (Number(tfs)\/1e6 | 0).toString().padStart(4)       , 'ms'       , '| total'       , (Number(duration)\/1e6 | 0).toString().padStart(4)       , 'ms'       );        if (active < n) {         active++;         process.emit('test:start');       }       else {         process.exit();       }     });    const n = 16;   Promise.all(     Array(n).fill().map(_ => new Promise((resolve, reject) => {       \/\/ \u0432\u044b\u0434\u0435\u043b\u044f\u0435\u043c \u0441\u0435\u0433\u043c\u0435\u043d\u0442\u044b \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u0438       const sharedBufferData = new SharedArrayBuffer(taskSize);       const sharedBufferLock = new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT);       \/\/ \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0438\u0440\u0443\u0435\u043c \"\u043f\u0443\u0441\u0442\u043e\u0435\" \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435 \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438       const lock = new Int32Array(sharedBufferLock);       lock.fill(THREAD_FREE);       \/\/ \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u043c \u0432 \u043f\u043e\u0442\u043e\u043a \u0441\u0441\u044b\u043b\u043a\u0438 \u043d\u0430 \u0441\u0435\u0433\u043c\u0435\u043d\u0442\u044b \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u0438       const worker = new Worker(__filename,         {           workerData : {             data : sharedBufferData           , lock : sharedBufferLock           }         }       );       worker.data = new Uint8Array(sharedBufferData);       worker.lock = lock;       worker         .on('online', () => resolve(worker))         .on('message', ({id, hash}) => {           hashes[id] = hash;           if (!--remain) {             process.emit('test:end');           }         });     }))   )     .then(result => {       workers.push(...result);       process.emit('test:start');     }); } else {   const {data, lock} = workerData;   const sharedData = new Uint8Array(data);   const sharedLock = new Int32Array(lock);    do {     const lock = Atomics.wait(sharedLock, 0, THREAD_FREE);     parentPort.postMessage({id : sharedLock[0], hash : createHash('sha256').update(sharedData).digest('hex')});     sharedLock[0] = THREAD_FREE;     Atomics.notify(sharedLock, 0, 1);   }   while (true); }<\/code><\/pre>\n
generated: 1959 ms hashed  1: 1237 ms | fs.read 4152 ms | total 5390 ms hashed  2:  616 ms | fs.read  555 ms | total 1171 ms hashed  3:  411 ms | fs.read  667 ms | total 1079 ms hashed  4:  344 ms | fs.read  801 ms | total 1145 ms hashed  5:  326 ms | fs.read  560 ms | total  887 ms hashed  6:  307 ms | fs.read  619 ms | total  926 ms hashed  7:  336 ms | fs.read  574 ms | total  911 ms hashed  8:  315 ms | fs.read  572 ms | total  887 ms hashed  9:  315 ms | fs.read  908 ms | total 1224 ms hashed 10:  305 ms | fs.read  904 ms | total 1209 ms hashed 11:  343 ms | fs.read  580 ms | total  924 ms hashed 12:  300 ms | fs.read  598 ms | total  899 ms hashed 13:  326 ms | fs.read  597 ms | total  924 ms hashed 14:  308 ms | fs.read  584 ms | total  893 ms hashed 15:  315 ms | fs.read  580 ms | total  895 ms hashed 16:  310 ms | fs.read  579 ms | total  890 ms<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\"\u0421\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439
\u0421\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0433\u043e \u043f\u043e\u0442\u043e\u043a\u0430 \u0441\u043d\u0438\u0436\u0430\u0435\u0442 \u043e\u0431\u0449\u0443\u044e \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c<\/figcaption><\/figure>\n
\u0412 \u0442\u043e\u0447\u043a\u0435 \u043c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u043e\u0439 \u044d\u0444\u0444\u0435\u043a\u0442\u0438\u0432\u043d\u043e\u0441\u0442\u0438 «4 \u043f\u043e\u0442\u043e\u043a\u0430 \u043d\u0430 4 \u044f\u0434\u0440\u0430\u0445<\/em>«, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043c\u044b \u0432\u044b\u0447\u0438\u0441\u043b\u0438\u043b\u0438 \u0432 \u043f\u0440\u043e\u0448\u043b\u044b\u0439 \u0440\u0430\u0437, \u0443\u0441\u043b\u043e\u0432\u043d\u043e «\u0447\u0438\u0441\u0442\u043e\u0435» \u0432\u0440\u0435\u043c\u044f \u0443\u0445\u0443\u0434\u0448\u0438\u043b\u043e\u0441\u044c \u043d\u0430 15%<\/strong> — \u0430 \u0432\u0435\u0434\u044c \u043c\u044b \u0432\u0441\u0435\u0433\u043e \u043b\u0438\u0448\u044c \u043d\u0430 \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u043e\u0435 \u0432\u0440\u0435\u043c\u044f \u0437\u0430\u043d\u044f\u043b\u0438 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u043f\u043e\u0442\u043e\u043a.<\/p>\n
\u041a \u0441\u043e\u0436\u0430\u043b\u0435\u043d\u0438\u044e, \u043e\u0442\u0440\u0435\u0430\u0433\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043d\u0430 \u043e\u0441\u0432\u043e\u0431\u043e\u0436\u0434\u0435\u043d\u0438\u0435 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0433\u043e \u043f\u043e\u0442\u043e\u043a\u0430 \u0438 \u0434\u0430\u0442\u044c \u0435\u043c\u0443 \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0443\u044e \u0437\u0430\u0434\u0430\u0447\u0443 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u043c\u043e\u0436\u0435\u0442 \u043d\u0435 \u0440\u0430\u043d\u044c\u0448\u0435, \u0447\u0435\u043c \u0437\u0430\u0432\u0435\u0440\u0448\u0438\u0442 \u0442\u0435\u043a\u0443\u0449\u0443\u044e \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u0443\u044e \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u044e<\/strong>:<\/p>\n
\"\u041e\u0436\u0438\u0434\u0430\u043d\u0438\u0435
\u041e\u0436\u0438\u0434\u0430\u043d\u0438\u0435 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0433\u043e \u043f\u043e\u0442\u043e\u043a\u0430 \u0438\u0437-\u0437\u0430 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430 \u0432 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u043c<\/figcaption><\/figure>\n
\u041f\u043e\u0442\u043e\u043a-\u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440<\/h2>\n
\u041d\u043e \u0434\u0430\u0432\u0430\u0439\u0442\u0435 \u0442\u043e\u0433\u0434\u0430 \u043f\u0440\u043e\u0446\u0435\u0441\u0441 «\u0440\u0430\u0437\u0434\u0430\u0447\u0438 \u0437\u0430\u0434\u0430\u043d\u0438\u0439» \u0432\u044b\u0442\u0430\u0449\u0438\u043c \u0432 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u043f\u043e\u0442\u043e\u043a, \u043e\u043f\u0438\u0441\u0430\u043d\u043d\u044b\u0439 \u0432\u043e \u0432\u0442\u043e\u0440\u043e\u0439 \u0447\u0430\u0441\u0442\u0438<\/a> \u043d\u0430\u0448\u0435\u0433\u043e \u0446\u0438\u043a\u043b\u0430 — \u043f\u0443\u0441\u0442\u044c \u0432 \u043d\u0435\u043c \u0431\u0443\u0434\u0435\u0442 \u043c\u0438\u043d\u0438\u043c\u0443\u043c \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430 \u0438 \u0435\u0433\u043e \u0440\u0435\u0430\u043a\u0446\u0438\u0438 \u043d\u0438\u0447\u0435\u043c \u043d\u0435 \u0437\u0430\u0442\u043e\u0440\u043c\u0430\u0436\u0438\u0432\u0430\u044e\u0442\u0441\u044f:<\/p>\n
<\/figcaption><\/figure>\n
\u0418\u0437 \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0433\u043e \u043f\u043e\u0442\u043e\u043a\u0430 \u043f\u0435\u0440\u0435\u0434\u0430\u0432\u0430\u0442\u044c \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044e \u0432 \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440 \u043c\u044b \u0431\u0443\u0434\u0435\u043c «\u043f\u043e \u0441\u0441\u044b\u043b\u043a\u0435», \u0431\u0435\u0437 \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f, \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e transferList<\/a>:<\/p>\n
            fns.forEach((fn, id) => {               const ts = hrtime();               const data = fs.readFileSync(fn); \/\/ \u0442\u044f\u0436\u0435\u043b\u044b\u0439 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434               tfs += hrtime() - ts;             \/\/ ... \u0438 \u0435\u0433\u043e \u043f\u0440\u043e\u0434\u043e\u043b\u0436\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c               coordinator.postMessage(                 {id, data}               , [data.buffer] \/\/ \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0430 \u043f\u043e \u0441\u0441\u044b\u043b\u043a\u0435 \u0447\u0435\u0440\u0435\u0437 transferList               );             });<\/code><\/pre>\n
… \u0430 \u0443\u0436\u0435 \u043c\u0435\u0436\u0434\u0443 \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440\u043e\u043c \u0438 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u043c\u0438 \u043f\u043e\u0442\u043e\u043a\u0430\u043c\u0438 — \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0447\u0435\u0440\u0435\u0437 \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u0443\u044e \u043f\u0430\u043c\u044f\u0442\u044c, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043f\u0435\u0440\u0435\u0434\u0430\u0434\u0438\u043c \u043f\u0440\u0438 \u0443\u0432\u044f\u0437\u043a\u0435 \u0434\u043e\u0447\u0435\u0440\u043d\u0438\u0445 \u043f\u043e\u0442\u043e\u043a\u043e\u0432:<\/p>\n
\/\/ ...         Promise.all(           workers.slice(0, active)             .flatMap(worker => {               const shared = { \/\/ \u0441\u0435\u0433\u043c\u0435\u043d\u0442\u044b \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u0438 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0433\u043e \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430                 data : worker.data               , lock : worker.lock               };               return [{worker}, {worker : coordinator, shared}];             })             .map(adressee => new Promise((resolve, reject) => {               const {worker, shared} = adressee;               worker.signalPort.once('message', () => resolve(adressee));               worker.signalPort.postMessage(shared); \/\/ shared \u043f\u043e\u043f\u0430\u0434\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e \u0432 \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440             }))         ) \/\/ ...<\/code><\/pre>\n
\u041d\u043e \u0435\u0441\u043b\u0438 \u043c\u044b \u043e\u0441\u0442\u0430\u0432\u0438\u043c \u0432 \u043f\u043e\u0442\u043e\u043a\u0435 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u044b\u0439 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u0446\u0438\u043a\u043b \u043e\u0436\u0438\u0434\u0430\u043d\u0438\u044f<\/strong> \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438, \u0443 \u043d\u0430\u0441 \u043f\u0440\u043e\u0439\u0434\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e \u043f\u0435\u0440\u0432\u044b\u0439 \u0442\u0435\u0441\u0442, \u0438 \u0432\u0441\u0435 \u0432\u0441\u0442\u0430\u043d\u0435\u0442 — \u043f\u043e\u0441\u043a\u043e\u043b\u044c\u043a\u0443 «\u0441\u043b\u0443\u0448\u0430\u0442\u044c» \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044e \u043e\u0442 \u043d\u043e\u0432\u043e\u0433\u043e \u044d\u043a\u0437\u0435\u043c\u043f\u043b\u044f\u0440\u0430 \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440\u0430 \u0431\u0443\u0434\u0435\u0442 \u0443\u0436\u0435 \u043d\u0435\u043a\u043e\u043c\u0443.<\/p>\n
\u041f\u043e\u044d\u0442\u043e\u043c\u0443 \u043f\u0435\u0440\u0435\u0432\u0435\u0434\u0435\u043c \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u0440\u0430\u0431\u043e\u0447\u0438\u0439 \u043a\u043e\u0434 \u0442\u043e\u0436\u0435 \u043d\u0430 Atomics.waitAsync<\/a>, \u0437\u0430\u043e\u0434\u043d\u043e \u0441\u043c\u043e\u0436\u0435\u043c \u0432\u0435\u0440\u043d\u0443\u0442\u044c \u0438 \u043e\u0446\u0435\u043d\u043a\u0443 \u0437\u0430\u0433\u0440\u0443\u0437\u043a\u0438 EventLoop:<\/p>\n
\/\/ ...     case 'worker':       const {data, lock} = workerData;       const sharedData = new Uint8Array(data);       const sharedLock = new Int32Array(lock);        const processMessage = () => {         \/\/ \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435         parentPort.postMessage({id : sharedLock[0], hash : createHash('sha256').update(sharedData).digest('hex')})         \/\/ \u0443\u0432\u0435\u0434\u043e\u043c\u043b\u044f\u0435\u043c \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440 \u043e \u0441\u0432\u043e\u0435\u0439 \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u043e\u0441\u0442\u0438         sharedLock[0] = THREAD_FREE;         Atomics.notify(sharedLock, 0, 1);         \/\/ ... \u0438 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c\u0441\u044f \u043a \u043e\u0436\u0438\u0434\u0430\u043d\u0438\u044e \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438         wait();       };        const wait = () => {         const lock = Atomics.waitAsync(sharedLock, 0, THREAD_FREE);         if (lock.value === 'not-equal') {           \/\/ \u0435\u0441\u043b\u0438 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 \u0438\u0437\u043c\u0435\u043d\u0438\u043b\u043e\u0441\u044c, \u0442\u043e \u043f\u043e\u0442\u043e\u043a \u0443\u0436\u0435 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u043b \u0437\u0430\u0434\u0430\u0447\u0443, \u0438 \u0440\u0435\u0430\u0433\u0438\u0440\u0443\u0435\u043c \u0441\u0440\u0430\u0437\u0443           processMessage();         }         else {           \/\/ \u0438\u043d\u0430\u0447\u0435 \u0436\u0434\u0435\u043c \u0440\u0430\u0437\u0440\u0435\u0448\u0435\u043d\u0438\u044f Promise \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438           lock.value.then(result => {             processMessage();           });         }       };       \/\/ \u0441\u0438\u0433\u043d\u0430\u043b\u0438\u0437\u0438\u0440\u0443\u0435\u043c \u0433\u043e\u0442\u043e\u0432\u043d\u043e\u0441\u0442\u044c \u0438 \u043d\u0430\u0447\u0438\u043d\u0430\u0435\u043c \u0436\u0434\u0430\u0442\u044c       signalPort.on('message', () => {         signalPort.postMessage(undefined);         wait();       });       break; \/\/ ...<\/code><\/pre>\n
\n\u041f\u043e\u043b\u043d\u044b\u0439 \u043a\u043e\u0434 \u0438 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b \u0442\u0435\u0441\u0442\u043e\u0432<\/summary>\n
\n
const {   Worker , isMainThread , parentPort , workerData , MessageChannel } = require('node:worker_threads');  const {   randomBytes , createHash } = require('node:crypto');  const hrtime = process.hrtime.bigint;  const THREAD_FREE = -1;  if (isMainThread) {   const taskSize = 1 << 16;      const tsg = hrtime();   const messages = Array(1 << 12).fill().map(_ => randomBytes(taskSize));    const fs = require('node:fs');   const {tmpdir} = require('node:os');   const {sep} = require('node:path');    \/\/ \u0441\u043e\u0437\u0434\u0430\u0435\u043c \u0432\u0440\u0435\u043c\u0435\u043d\u043d\u0443\u044e \u043f\u0430\u043f\u043a\u0443 \u0438 \u0432 \u043d\u0435\u0439 \u0444\u0430\u0439\u043b\u044b \u0441\u043e \u0432\u0441\u0435\u043c\u0438 \"\u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\u043c\u0438\"   const dir = fs.mkdtempSync(tmpdir() + sep);   messages.forEach((data, i) => {     const fn = i.toString(16).padStart(3, '0');     fs.writeFileSync(dir + sep + fn, data);   });   console.log('generated:', Number(hrtime() - tsg)\/1e6 | 0, 'ms');    const hashes = messages.map(() => undefined);   let remain;    const workers = [];   let active = 1;   let tsh;   let tfs;    let coordinator;   process     .on('test:start', () => {       hashes.fill();        const channel = new MessageChannel();       coordinator = new Worker(__filename,         {           workerData   : {             signalPort : channel.port1           , workerType : 'coordinator'           }         , transferList : [channel.port1]         }       );       coordinator.signalPort = channel.port2;       coordinator.signalPort.setMaxListeners(0);        coordinator.on('online', () => {         Promise.all(           workers.slice(0, active)             .flatMap(worker => {               const shared = { \/\/ \u0441\u0435\u0433\u043c\u0435\u043d\u0442\u044b \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u0438 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u043e\u0433\u043e \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430                 data : worker.data               , lock : worker.lock               };               return [{worker}, {worker : coordinator, shared}];             })             .map(adressee => new Promise((resolve, reject) => {               const {worker, shared} = adressee;               worker.signalPort.once('message', () => resolve(adressee));               worker.signalPort.postMessage(shared); \/\/ shared \u043f\u043e\u043f\u0430\u0434\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e \u0432 \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440             }))         )           .then(result => {             \/\/ \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u0441\u043f\u0438\u0441\u043e\u043a \u0432\u0441\u0435\u0445 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439             const fns = fs.readdirSync(dir)               .sort()               .map(fn => dir + sep + fn);             remain = fns.length;              [coordinator, ...workers].forEach(worker => worker.eLU = worker.performance.eventLoopUtilization());             tsh = hrtime();             tfs = 0n;              fns.forEach((fn, id) => {               const ts = hrtime();               const data = fs.readFileSync(fn); \/\/ \u0442\u044f\u0436\u0435\u043b\u044b\u0439 \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043a\u043e\u0434               tfs += hrtime() - ts;             \/\/ ... \u0438 \u0435\u0433\u043e \u043f\u0440\u043e\u0434\u043e\u043b\u0436\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c               coordinator.postMessage(                 {id, data}               , [data.buffer] \/\/ \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0430 \u043f\u043e \u0441\u0441\u044b\u043b\u043a\u0435 \u0447\u0435\u0440\u0435\u0437 transferList               );             });           });       });     })     .on('test:end', () => {       const duration = hrtime() - tsh;       [coordinator, ...workers].forEach(worker => worker.util = worker.performance.eventLoopUtilization(worker.eLU).utilization);       const avg = workers.slice(0, active).reduce((sum, worker) => sum + worker.util, 0)\/active;        console.log(         'hashed ' + active.toString().padStart(2) + ':'       , (Number(duration - tfs)\/1e6 | 0).toString().padStart(4)       , 'ms'       , '| fs.read'       , (Number(tfs)\/1e6 | 0).toString().padStart(4)       , 'ms'       , '| total'       , (Number(duration)\/1e6 | 0).toString().padStart(4)       , 'ms | ' + (avg * 100 | 0) + ' | '       , (coordinator.util * 100 | 0).toString().padStart(3) + ' c'       , workers.map(           worker => (worker.util * 100 | 0).toString().padStart(3)         ).join(' ')       );        if (active < n) {         active++;         process.emit('test:start');       }       else {         process.exit();       }     });    const n = 16;   Promise.all(     Array(n).fill().map(_ => new Promise((resolve, reject) => {       \/\/ \u0432\u044b\u0434\u0435\u043b\u044f\u0435\u043c \u0441\u0435\u0433\u043c\u0435\u043d\u0442\u044b \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u0438       const sharedBufferData = new SharedArrayBuffer(taskSize);       const sharedBufferLock = new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT);       \/\/ \u0438\u043d\u0438\u0446\u0438\u0430\u043b\u0438\u0437\u0438\u0440\u0443\u0435\u043c \"\u043f\u0443\u0441\u0442\u043e\u0435\" \u0441\u043e\u0441\u0442\u043e\u044f\u043d\u0438\u0435 \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438       const lock = new Int32Array(sharedBufferLock);       lock.fill(THREAD_FREE);        const channel = new MessageChannel();       \/\/ \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u043c \u0432 \u043f\u043e\u0442\u043e\u043a \u0441\u0441\u044b\u043b\u043a\u0438 \u043d\u0430 \u0441\u0435\u0433\u043c\u0435\u043d\u0442\u044b \u0440\u0430\u0437\u0434\u0435\u043b\u044f\u0435\u043c\u043e\u0439 \u043f\u0430\u043c\u044f\u0442\u0438       const worker = new Worker(__filename,         {           workerData : {             signalPort : channel.port1           , workerType : 'worker'           , data : sharedBufferData           , lock : sharedBufferLock           }         , transferList : [channel.port1]         }       );       worker.signalPort = channel.port2;       worker.data = new Uint8Array(sharedBufferData);       worker.lock = lock;       worker         .on('online', () => resolve(worker))         .on('message', ({id, hash}) => {           hashes[id] = hash;           if (!--remain) {             process.emit('test:end');           }         });     }))   )     .then(result => {       workers.push(...result);       process.emit('test:start');     }); } else {   const {signalPort, workerType} = workerData;   switch (workerType) {     case 'worker':       const {data, lock} = workerData;       const sharedData = new Uint8Array(data);       const sharedLock = new Int32Array(lock);        const processMessage = () => {         \/\/ \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435         parentPort.postMessage({id : sharedLock[0], hash : createHash('sha256').update(sharedData).digest('hex')})         \/\/ \u0443\u0432\u0435\u0434\u043e\u043c\u043b\u044f\u0435\u043c \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440 \u043e \u0441\u0432\u043e\u0435\u0439 \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u043e\u0441\u0442\u0438         sharedLock[0] = THREAD_FREE;         Atomics.notify(sharedLock, 0, 1);         \/\/ ... \u0438 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c\u0441\u044f \u043a \u043e\u0436\u0438\u0434\u0430\u043d\u0438\u044e \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438         wait();       };        const wait = () => {         const lock = Atomics.waitAsync(sharedLock, 0, THREAD_FREE);         if (lock.value === 'not-equal') {           \/\/ \u0435\u0441\u043b\u0438 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 \u0438\u0437\u043c\u0435\u043d\u0438\u043b\u043e\u0441\u044c, \u0442\u043e \u043f\u043e\u0442\u043e\u043a \u0443\u0436\u0435 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u043b \u0437\u0430\u0434\u0430\u0447\u0443, \u0438 \u0440\u0435\u0430\u0433\u0438\u0440\u0443\u0435\u043c \u0441\u0440\u0430\u0437\u0443           processMessage();         }         else {           \/\/ \u0438\u043d\u0430\u0447\u0435 \u0436\u0434\u0435\u043c \u0440\u0430\u0437\u0440\u0435\u0448\u0435\u043d\u0438\u044f Promise \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438           lock.value.then(result => {             processMessage();           });         }       };       \/\/ \u0441\u0438\u0433\u043d\u0430\u043b\u0438\u0437\u0438\u0440\u0443\u0435\u043c \u0433\u043e\u0442\u043e\u0432\u043d\u043e\u0441\u0442\u044c \u0438 \u043d\u0430\u0447\u0438\u043d\u0430\u0435\u043c \u0436\u0434\u0430\u0442\u044c       signalPort.on('message', () => {         signalPort.postMessage(undefined);         wait();       });       break;     case 'coordinator':       const pool = [];       const queue = new (require('.\/Pow2Buffer'))(8, 16);        const shareMessage = (worker, {id, data}) => {         worker.data.set(data, 0);         worker.lock[0] = id;         Atomics.notify(worker.lock, 0, 1);          const lock = Atomics.waitAsync(worker.lock, 0, id);         if (lock.value === 'not-equal') {           \/\/ \u0435\u0441\u043b\u0438 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 \u0438\u0437\u043c\u0435\u043d\u0438\u043b\u043e\u0441\u044c, \u0442\u043e \u043f\u043e\u0442\u043e\u043a \u0443\u0436\u0435 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u043b \u0437\u0430\u0434\u0430\u0447\u0443, \u0438 \u0440\u0435\u0430\u0433\u0438\u0440\u0443\u0435\u043c \u0441\u0440\u0430\u0437\u0443           onMessage(worker);         }         else {           \/\/ \u0438\u043d\u0430\u0447\u0435 \u0436\u0434\u0435\u043c \u0440\u0430\u0437\u0440\u0435\u0448\u0435\u043d\u0438\u044f Promise \u0431\u043b\u043e\u043a\u0438\u0440\u043e\u0432\u043a\u0438           lock.value.then(result => {             onMessage(worker);           });         }       }        const onMessage = worker => {         const msg = queue.shift();         if (msg) {           shareMessage(worker, msg);         }         else {           pool.push(worker);         }       }        \/\/ \u043f\u043e \u0441\u0438\u0433\u043d\u0430\u043b\u044c\u043d\u043e\u043c\u0443 \u043a\u0430\u043d\u0430\u043b\u0443 \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u043c \u043f\u043e\u0440\u0442 worker'\u0430       signalPort.on('message', worker => {         \/\/ \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0435\u043c \u0432 \u043f\u0443\u043b \u0438 \u043f\u043e\u0434\u043f\u0438\u0441\u044b\u0432\u0430\u0435\u043c\u0441\u044f \u043d\u0430 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0443 \u0441\u0438\u0433\u043d\u0430\u043b\u0430 \u0433\u043e\u0442\u043e\u0432\u043d\u043e\u0441\u0442\u0438 \u043e\u0442 worker'\u0430         pool.push(worker);         signalPort.postMessage(undefined);       });       \/\/ \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u0432\u0445\u043e\u0434\u044f\u0449\u0435\u0433\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440\u0443       parentPort.on('message', message => {         const worker = pool.pop();         if (worker) {           shareMessage(worker, message);         }         else {           queue.push(message);         }       });       break;   } }<\/code><\/pre>\n
generated: 2043 ms hashed  1:  373 ms | fs.read 2387 ms | total 2761 ms | 42 |   10 c  42   0   0   0   0   0   0   0   0   0   0   0   0   0   0   0 hashed  2:  118 ms | fs.read  602 ms | total  720 ms | 89 |   39 c  98  79   0   0   0   0   0   0   0   0   0   0   0   0   0   0 hashed  3:  119 ms | fs.read  570 ms | total  690 ms | 80 |   33 c 100  99  40   0   0   0   0   0   0   0   0   0   0   0   0   0 hashed  4:   75 ms | fs.read  603 ms | total  679 ms | 77 |   23 c 100 100  96  12   0   0   0   0   0   0   0   0   0   0   0   0 hashed  5:  204 ms | fs.read  931 ms | total 1135 ms | 81 |   27 c 100 100 100  98  11   0   0   0   0   0   0   0   0   0   0   0 hashed  6:  146 ms | fs.read  994 ms | total 1141 ms | 82 |   12 c 100 100 100 100  88   9   0   0   0   0   0   0   0   0   0   0 hashed  7:  260 ms | fs.read  952 ms | total 1212 ms | 81 |   22 c 100 100 100 100 100  67   5   0   1   0   0   0   1   1   0   1 hashed  8:  142 ms | fs.read 1433 ms | total 1576 ms | 89 |   16 c 100 100 100 100 100 100 100  13   0   0   0   0   0   0   0   0 hashed  9:  253 ms | fs.read 1554 ms | total 1807 ms | 86 |    9 c 100 100 100 100 100 100 100  74   0   0   0   0   0   0   0   0 hashed 10:  196 ms | fs.read 1587 ms | total 1784 ms | 80 |    7 c 100 100 100 100 100 100 100 100   6   2   0   0   0   0   0   0 hashed 11:  311 ms | fs.read 1948 ms | total 2259 ms | 87 |   21 c 100 100 100 100 100 100 100 100  81  81   4   0   0   0   0   0 hashed 12:  237 ms | fs.read 1973 ms | total 2210 ms | 83 |    7 c 100 100 100 100 100 100 100 100 100 100   0   0   0   0   0   0 hashed 13:  362 ms | fs.read 2014 ms | total 2377 ms | 78 |   14 c 100 100 100 100 100 100 100 100 100 100   5   5   8   0   0   0 hashed 14:   73 ms | fs.read 2280 ms | total 2354 ms | 77 |    6 c 100 100 100 100 100 100 100 100 100 100   7  38  37   5   0   0 hashed 15:  413 ms | fs.read 2513 ms | total 2927 ms | 83 |   12 c 100 100 100 100 100 100 100 100 100 100  52 100 100   3   1   0 hashed 16:  241 ms | fs.read 2619 ms | total 2861 ms | 86 |   21 c 100 100 100 100 100 100 100 100 100 100 100 100 100  52  11  12<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\"\u041a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440
\u041a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440 \u0440\u0435\u0448\u0430\u0435\u0442!<\/figcaption><\/figure>\n
\u041a\u043e\u0434 \u043d\u0430\u0448\u0435\u0433\u043e \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u0443\u0436\u0435 \u0441\u043e\u0432\u0441\u0435\u043c \u043f\u0435\u0440\u0435\u0441\u0442\u0430\u043b \u0431\u044b\u0442\u044c \u043f\u0440\u043e\u0441\u0442\u044b\u043c, \u043d\u043e \u0437\u0430\u0442\u043e \u043c\u044b \u0432\u0441\u0435-\u0442\u0430\u043a\u0438 \u0435\u0449\u0435 \u043f\u043e\u0447\u0442\u0438 \u0432 4 \u0440\u0430\u0437\u0430 \u0443\u043c\u0435\u043d\u044c\u0448\u0438\u043b\u0438<\/strong> \u0432\u0440\u0435\u043c\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438.<\/p>\n
\u041f\u0440\u0438 \u044d\u0442\u043e\u043c \u043f\u043e \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440\u0443 \u0435\u0449\u0435 \u043e\u0441\u0442\u0430\u0435\u0442\u0441\u044f \u0437\u0430\u043f\u0430\u0441 \u0434\u043b\u044f \u0434\u0440\u0443\u0433\u043e\u0439 \u043f\u043e\u043b\u0435\u0437\u043d\u043e\u0439 \u0440\u0430\u0431\u043e\u0442\u044b — \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0434\u043b\u044f \u0434\u0438\u043d\u0430\u043c\u0438\u0447\u0435\u0441\u043a\u043e\u0433\u043e \u0443\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u044f \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e\u043c \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0445 \u043f\u043e\u0442\u043e\u043a\u043e\u0432. \u041d\u043e \u043f\u0440\u043e \u044d\u0442\u043e — \u0432 \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u0439 \u0447\u0430\u0441\u0442\u0438.<\/p>\n\n