deno.land / std@0.157.0 / node / testdata / worker_threads.ts
12345678910111213141516171819202122232425262728293031import { getEnvironmentData, isMainThread, parentPort, threadId, workerData,} from "../worker_threads.ts";import { once } from "../events.ts";
async function message(expectedMessage: string) { const [message] = await once(parentPort, "message"); if (message !== expectedMessage) { console.log(`Expected the message "${expectedMessage}", but got`, message); // fail test parentPort.close(); }}
await message("Hello, how are you my thread?");parentPort.postMessage("I'm fine!");
parentPort.postMessage({ isMainThread, threadId, workerData: Array.isArray(workerData) && workerData[workerData.length - 1] instanceof MessagePort ? workerData.slice(0, -1) : workerData, envData: [getEnvironmentData("test"), getEnvironmentData(1)],});
Version Info