Skip to content

Commit 01e44dc

Browse files
authored
worker: update code examples for node:worker_threads module
PR-URL: #58264 Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Antoine du Hamel <duhamelantoine1995@gmail.com>
1 parent 4593b43 commit 01e44dc

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

doc/api/worker_threads.md

Lines changed: 8 additions & 8 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,7 +670,7 @@ 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
```
@@ -680,7 +680,7 @@ new Worker('process.env.SET_IN_WORKER = "foo"', { eval: true, env: SHARE_ENV })
680680
681681
const { Worker, SHARE_ENV } = require('node:worker_threads');
682682
new Worker('process.env.SET_IN_WORKER = "foo"', { eval: true, env: SHARE_ENV })
683-
.on('exit', () => {
683+
.once('exit', () => {
684684
console.log(process.env.SET_IN_WORKER); // Prints 'foo'.
685685
});
686686
```
@@ -1110,7 +1110,7 @@ const { port1, port2 } = new MessageChannel();
11101110
// foobar
11111111
// closed!
11121112
port2.on('message', (message) => console.log(message));
1113-
port2.on('close', () => console.log('closed!'));
1113+
port2.once('close', () => console.log('closed!'));
11141114

11151115
port1.postMessage('foobar');
11161116
port1.close();
@@ -1126,7 +1126,7 @@ const { port1, port2 } = new MessageChannel();
11261126
// foobar
11271127
// closed!
11281128
port2.on('message', (message) => console.log(message));
1129-
port2.on('close', () => console.log('closed!'));
1129+
port2.once('close', () => console.log('closed!'));
11301130

11311131
port1.postMessage('foobar');
11321132
port1.close();

0 commit comments

Comments
 (0)