summaryrefslogtreecommitdiff
path: root/tests/unit_node/testdata/worker_threads2.mjs
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2024-03-11 22:59:42 +0000
committerGitHub <noreply@github.com>2024-03-11 22:59:42 +0000
commit47f318230fe9b4870610cbfbaae424a28818a8d0 (patch)
tree9ded54b81f6d2583ff263e292f889851d41ca975 /tests/unit_node/testdata/worker_threads2.mjs
parenta77b2987bc90879af30a39ba274df9061cc7fbae (diff)
test(ext/node): add worker_threads test for SharedArrayBuffer (#22850)
Follow up to https://github.com/denoland/deno/pull/22815
Diffstat (limited to 'tests/unit_node/testdata/worker_threads2.mjs')
-rw-r--r--tests/unit_node/testdata/worker_threads2.mjs17
1 files changed, 17 insertions, 0 deletions
diff --git a/tests/unit_node/testdata/worker_threads2.mjs b/tests/unit_node/testdata/worker_threads2.mjs
new file mode 100644
index 000000000..52d906bdf
--- /dev/null
+++ b/tests/unit_node/testdata/worker_threads2.mjs
@@ -0,0 +1,17 @@
+// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
+import { parentPort, workerData } from "node:worker_threads";
+import { once } from "node:events";
+
+async function message(expectedMessage) {
+ const [message] = await once(parentPort, "message");
+ if (message !== expectedMessage) {
+ console.log(`Expected the message "${expectedMessage}", but got`, message);
+ // fail test
+ parentPort.close();
+ }
+}
+
+const uint = new Uint8Array(workerData.sharedArrayBuffer);
+uint[0]++;
+await message("Hello");
+parentPort.postMessage("Hello");