diff --git a/doc/api/worker_threads.md b/doc/api/worker_threads.md index 40d22d337553cb..97954661ada5be 100644 --- a/doc/api/worker_threads.md +++ b/doc/api/worker_threads.md @@ -47,8 +47,8 @@ export default function parseJSAsync(script) { workerData: script, }); worker.on('message', resolve); - worker.on('error', reject); - worker.on('exit', (code) => { + worker.once('error', reject); + worker.once('exit', (code) => { if (code !== 0) reject(new Error(`Worker stopped with exit code ${code}`)); }); @@ -73,8 +73,8 @@ if (isMainThread) { workerData: script, }); worker.on('message', resolve); - worker.on('error', reject); - worker.on('exit', (code) => { + worker.once('error', reject); + worker.once('exit', (code) => { if (code !== 0) reject(new Error(`Worker stopped with exit code ${code}`)); }); @@ -670,7 +670,7 @@ share read and write access to the same set of environment variables. import process from 'node:process'; import { Worker, SHARE_ENV } from 'node:worker_threads'; new Worker('process.env.SET_IN_WORKER = "foo"', { eval: true, env: SHARE_ENV }) - .on('exit', () => { + .once('exit', () => { console.log(process.env.SET_IN_WORKER); // Prints 'foo'. }); ``` @@ -680,7 +680,7 @@ new Worker('process.env.SET_IN_WORKER = "foo"', { eval: true, env: SHARE_ENV }) const { Worker, SHARE_ENV } = require('node:worker_threads'); new Worker('process.env.SET_IN_WORKER = "foo"', { eval: true, env: SHARE_ENV }) - .on('exit', () => { + .once('exit', () => { console.log(process.env.SET_IN_WORKER); // Prints 'foo'. }); ``` @@ -950,7 +950,7 @@ const { port1, port2 } = new MessageChannel(); // foobar // closed! port2.on('message', (message) => console.log(message)); -port2.on('close', () => console.log('closed!')); +port2.once('close', () => console.log('closed!')); port1.postMessage('foobar'); port1.close(); @@ -966,7 +966,7 @@ const { port1, port2 } = new MessageChannel(); // foobar // closed! port2.on('message', (message) => console.log(message)); -port2.on('close', () => console.log('closed!')); +port2.once('close', () => console.log('closed!')); port1.postMessage('foobar'); port1.close();