Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- const { Worker, isMainThread } = require("worker_threads");
- function runService(workerData) {
- const worker = new Worker("./service.js", { workerData });
- worker.postMessage("once");
- worker.on("message", incoming => console.log({ incoming }));
- worker.on("error", code => new Error(`Worker error with exit code ${code}`));
- worker.on("exit", code =>
- console.log(`Worker stopped with exit code ${code}`)
- );
- worker.postMessage("twice");
- worker.postMessage("three times");
- worker.postMessage("exit");
- setTimeout(() => worker.postMessage("you won't see me"), 100);
- }
- async function run() {
- const result = runService("let's begin");
- console.log({ isMainThread });
- }
- run().catch(err => console.error(err));
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement