diff options
author | Satya Rohith <me@satyarohith.com> | 2024-05-03 11:22:47 +0530 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-05-03 05:52:47 +0000 |
commit | 02d0ff58d2bab24ebbd1e61afe6b571ff4c415af (patch) | |
tree | 78b7fa4e7cf0265d688e34ddaa422ec344273e06 /tests/testdata/workers | |
parent | 3e98ea4e69732d8a659ca0ca61747fe3887ab673 (diff) |
refactor(tests): move worker_threads itests to spec tests (#23648)
Diffstat (limited to 'tests/testdata/workers')
10 files changed, 0 insertions, 147 deletions
diff --git a/tests/testdata/workers/node_worker_auto_exits.mjs b/tests/testdata/workers/node_worker_auto_exits.mjs deleted file mode 100644 index e434f59f7..000000000 --- a/tests/testdata/workers/node_worker_auto_exits.mjs +++ /dev/null @@ -1,19 +0,0 @@ -import { isMainThread, parentPort, Worker } from "node:worker_threads"; - -function onMessageOneshot() { - console.log("Got message from main thread!"); - parentPort.off("message", onMessageOneshot); -} - -if (isMainThread) { - // This re-loads the current file inside a Worker instance. - const w = new Worker(import.meta.filename); - - setTimeout(() => { - w.postMessage("Hello! I am from the main thread."); - }, 500); -} else { - console.log("Inside Worker!"); - console.log(isMainThread); // Prints 'false'. - parentPort.on("message", onMessageOneshot); -} diff --git a/tests/testdata/workers/node_worker_auto_exits.mjs.out b/tests/testdata/workers/node_worker_auto_exits.mjs.out deleted file mode 100644 index a160931db..000000000 --- a/tests/testdata/workers/node_worker_auto_exits.mjs.out +++ /dev/null @@ -1,3 +0,0 @@ -Inside Worker! -false -Got message from main thread! diff --git a/tests/testdata/workers/node_worker_message_port.mjs b/tests/testdata/workers/node_worker_message_port.mjs deleted file mode 100644 index 91c7e062d..000000000 --- a/tests/testdata/workers/node_worker_message_port.mjs +++ /dev/null @@ -1,41 +0,0 @@ -import workerThreads from "node:worker_threads"; - -const { port1: mainPort, port2: workerPort } = new workerThreads - .MessageChannel(); - -// Note: not using Promise.withResolver() because it's not available in Node.js -const deferred = createDeferred(); - -const worker = new workerThreads.Worker( - import.meta.resolve("./node_worker_message_port_1.cjs"), - { - workerData: workerPort, - transferList: [workerPort], - }, -); - -worker.on("message", (data) => { - console.log("worker:", data); - mainPort.on("message", (msg) => { - console.log("mainPort:", msg); - deferred.resolve(); - }); - mainPort.on("close", (_msg) => { - console.log("mainPort closed"); - }); -}); - -worker.postMessage("Hello from parent"); -await deferred.promise; -await worker.terminate(); -mainPort.close(); - -function createDeferred() { - let resolveCallback; - let rejectCallback; - const promise = new Promise((resolve, reject) => { - resolveCallback = resolve; - rejectCallback = reject; - }); - return { promise, resolve: resolveCallback, reject: rejectCallback }; -} diff --git a/tests/testdata/workers/node_worker_message_port.mjs.out b/tests/testdata/workers/node_worker_message_port.mjs.out deleted file mode 100644 index 95b4fbc96..000000000 --- a/tests/testdata/workers/node_worker_message_port.mjs.out +++ /dev/null @@ -1,6 +0,0 @@ -[UNORDERED_START] -worker port closed -worker: Hello from worker on parentPort! -mainPort: Hello from worker on workerPort! -mainPort closed -[UNORDERED_END] diff --git a/tests/testdata/workers/node_worker_message_port_1.cjs b/tests/testdata/workers/node_worker_message_port_1.cjs deleted file mode 100644 index 3f78cd539..000000000 --- a/tests/testdata/workers/node_worker_message_port_1.cjs +++ /dev/null @@ -1,9 +0,0 @@ -const { parentPort, workerData } = require("worker_threads"); - -parentPort.on("message", (msg) => { - const workerPort = workerData; - parentPort.postMessage("Hello from worker on parentPort!"); - workerPort.postMessage("Hello from worker on workerPort!"); - workerPort.on("close", () => console.log("worker port closed")); - workerPort.close(); -}); diff --git a/tests/testdata/workers/node_worker_message_port_unref.mjs b/tests/testdata/workers/node_worker_message_port_unref.mjs deleted file mode 100644 index a12be1ec8..000000000 --- a/tests/testdata/workers/node_worker_message_port_unref.mjs +++ /dev/null @@ -1,40 +0,0 @@ -import { - isMainThread, - MessageChannel, - parentPort, - Worker, - workerData, -} from "node:worker_threads"; - -const useParentPort = Deno.env.get("PARENT_PORT") === "1"; - -if (useParentPort) { - if (isMainThread) { - const worker = new Worker(import.meta.filename); - worker.postMessage("main says hi!"); - worker.on("message", (msg) => console.log(msg)); - } else { - parentPort.on("message", (msg) => { - console.log(msg); - parentPort.postMessage("worker says hi!"); - parentPort.unref(); - }); - } -} else { - if (isMainThread) { - const { port1, port2 } = new MessageChannel(); - const worker = new Worker(import.meta.filename, { - workerData: port2, - transferList: [port2], - }); - port1.postMessage("main says hi!"); - port1.on("message", (msg) => console.log(msg)); - } else { - const port = workerData; - port.on("message", (msg) => { - console.log(msg); - port.postMessage("worker says hi!"); - port.unref(); - }); - } -} diff --git a/tests/testdata/workers/node_worker_message_port_unref.mjs.out b/tests/testdata/workers/node_worker_message_port_unref.mjs.out deleted file mode 100644 index c9d5325bc..000000000 --- a/tests/testdata/workers/node_worker_message_port_unref.mjs.out +++ /dev/null @@ -1,2 +0,0 @@ -main says hi! -worker says hi! diff --git a/tests/testdata/workers/node_worker_transfer_port.mjs b/tests/testdata/workers/node_worker_transfer_port.mjs deleted file mode 100644 index 1b17ed1ab..000000000 --- a/tests/testdata/workers/node_worker_transfer_port.mjs +++ /dev/null @@ -1,14 +0,0 @@ -import { MessageChannel, Worker } from "node:worker_threads"; - -const { port1, port2 } = new MessageChannel(); -const worker = new Worker( - import.meta.resolve("./node_worker_transfer_port_1.mjs"), -); -// Send the port directly after the worker is created -worker.postMessage(port2, [port2]); -// Send a message to the worker using the transferred port -port1.postMessage("Hello from main thread!"); -worker.on("message", (message) => { - console.log("Received message from worker:", message); - worker.terminate(); -}); diff --git a/tests/testdata/workers/node_worker_transfer_port.mjs.out b/tests/testdata/workers/node_worker_transfer_port.mjs.out deleted file mode 100644 index 8e8f11940..000000000 --- a/tests/testdata/workers/node_worker_transfer_port.mjs.out +++ /dev/null @@ -1,3 +0,0 @@ -Worker thread started! -Received message from main thread: Hello from main thread! -Received message from worker: Reply from worker diff --git a/tests/testdata/workers/node_worker_transfer_port_1.mjs b/tests/testdata/workers/node_worker_transfer_port_1.mjs deleted file mode 100644 index 4d0a38bd5..000000000 --- a/tests/testdata/workers/node_worker_transfer_port_1.mjs +++ /dev/null @@ -1,10 +0,0 @@ -import { parentPort } from "node:worker_threads"; - -parentPort.on("message", (message) => { - const transferredPort = message; - transferredPort.on("message", (message) => { - console.log("Received message from main thread:", message); - parentPort.postMessage("Reply from worker"); - }); - console.log("Worker thread started!"); -}); |