diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2024-03-11 22:59:42 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-03-11 22:59:42 +0000 |
commit | 47f318230fe9b4870610cbfbaae424a28818a8d0 (patch) | |
tree | 9ded54b81f6d2583ff263e292f889851d41ca975 /tests/unit_node/testdata/worker_threads2.mjs | |
parent | a77b2987bc90879af30a39ba274df9061cc7fbae (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.mjs | 17 |
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"); |