diff options
Diffstat (limited to 'tests/testdata/workers/worker_ids_are_sequential.ts')
-rw-r--r-- | tests/testdata/workers/worker_ids_are_sequential.ts | 34 |
1 files changed, 0 insertions, 34 deletions
diff --git a/tests/testdata/workers/worker_ids_are_sequential.ts b/tests/testdata/workers/worker_ids_are_sequential.ts deleted file mode 100644 index eb90f0d47..000000000 --- a/tests/testdata/workers/worker_ids_are_sequential.ts +++ /dev/null @@ -1,34 +0,0 @@ -import { - isMainThread, - parentPort, - threadId, - Worker, -} from "node:worker_threads"; - -console.log("threadId", threadId); - -if (isMainThread) { - const worker = new Worker(new URL(import.meta.url)); - worker.on("message", (msg) => console.log("from worker:", msg)); - worker.on("error", () => { - throw new Error("error"); - }); - worker.on("exit", (code) => { - if (code !== 0) { - reject(new Error(`Worker stopped with exit code ${code}`)); - } - }); -} else if (threadId == 1) { - const worker = new Worker(new URL(import.meta.url)); - worker.on("message", (msg) => console.log("from worker:", msg)); - worker.on("error", () => { - throw new Error("error"); - }); - worker.on("exit", (code) => { - if (code !== 0) { - reject(new Error(`Worker stopped with exit code ${code}`)); - } - }); -} else { - parentPort.postMessage("hello!"); -} |