Skip to content

Commit 3d8d62c

Browse files
committed
worker: update code examples for node:worker_threads module
1 parent 6710c00 commit 3d8d62c

File tree

1 file changed

+11
-10
lines changed

1 file changed

+11
-10
lines changed

doc/api/worker_threads.md

Lines changed: 11 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,8 @@ export default function parseJSAsync(script) {
4747
workerData: script,
4848
});
4949
worker.on('message', resolve);
50-
worker.on('error', reject);
51-
worker.on('exit', (code) => {
50+
worker.once('error', reject);
51+
worker.once('exit', (code) => {
5252
if (code !== 0)
5353
reject(new Error(`Worker stopped with exit code ${code}`));
5454
});
@@ -73,8 +73,8 @@ if (isMainThread) {
7373
workerData: script,
7474
});
7575
worker.on('message', resolve);
76-
worker.on('error', reject);
77-
worker.on('exit', (code) => {
76+
worker.once('error', reject);
77+
worker.once('exit', (code) => {
7878
if (code !== 0)
7979
reject(new Error(`Worker stopped with exit code ${code}`));
8080
});
@@ -670,17 +670,18 @@ share read and write access to the same set of environment variables.
670670
import process from 'node:process';
671671
import { Worker, SHARE_ENV } from 'node:worker_threads';
672672
new Worker('process.env.SET_IN_WORKER = "foo"', { eval: true, env: SHARE_ENV })
673-
.on('exit', () => {
673+
.once('exit', () => {
674674
console.log(process.env.SET_IN_WORKER); // Prints 'foo'.
675675
});
676676
```
677677
678678
```cjs
679679
'use strict';
680680
681+
const process = require('node:process');
681682
const { Worker, SHARE_ENV } = require('node:worker_threads');
682683
new Worker('process.env.SET_IN_WORKER = "foo"', { eval: true, env: SHARE_ENV })
683-
.on('exit', () => {
684+
.once('exit', () => {
684685
console.log(process.env.SET_IN_WORKER); // Prints 'foo'.
685686
});
686687
```
@@ -950,7 +951,7 @@ const { port1, port2 } = new MessageChannel();
950951
// foobar
951952
// closed!
952953
port2.on('message', (message) => console.log(message));
953-
port2.on('close', () => console.log('closed!'));
954+
port2.once('close', () => console.log('closed!'));
954955

955956
port1.postMessage('foobar');
956957
port1.close();
@@ -966,7 +967,7 @@ const { port1, port2 } = new MessageChannel();
966967
// foobar
967968
// closed!
968969
port2.on('message', (message) => console.log(message));
969-
port2.on('close', () => console.log('closed!'));
970+
port2.once('close', () => console.log('closed!'));
970971

971972
port1.postMessage('foobar');
972973
port1.close();
@@ -1384,7 +1385,7 @@ and what kind of JavaScript values can be successfully transported through
13841385
the thread barrier.
13851386
13861387
```mjs
1387-
import assert from 'node:assert';
1388+
import assert from 'node:assert/strict';
13881389
import {
13891390
Worker, MessageChannel, MessagePort, isMainThread, parentPort,
13901391
} from 'node:worker_threads';
@@ -1407,7 +1408,7 @@ if (isMainThread) {
14071408
```cjs
14081409
'use strict';
14091410

1410-
const assert = require('node:assert');
1411+
const assert = require('node:assert/strict');
14111412
const {
14121413
Worker, MessageChannel, MessagePort, isMainThread, parentPort,
14131414
} = require('node:worker_threads');

0 commit comments

Comments
 (0)