1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
import { Worker as NodeWorker } from "node:worker_threads";
import * as tsd from "tsd";
const webWorker = new Worker("./worker.js");
webWorker.addEventListener("message", event => {
tsd.expectType<MessageEvent>(event);
});
webWorker.addEventListener("error", event => {
tsd.expectType<ErrorEvent>(event);
});
webWorker.addEventListener("messageerror", event => {
tsd.expectType<MessageEvent>(event);
});
const nodeWorker = new NodeWorker("./worker.ts");
nodeWorker.on("message", event => {
console.log("Message from worker:", event);
});
nodeWorker.postMessage("Hello from main thread!");
const workerURL = new URL("worker.ts", import.meta.url).href;
const _worker2 = new Worker(workerURL);
nodeWorker.postMessage("hello");
webWorker.onmessage = event => {
console.log(event.data);
};
// On the worker thread, `postMessage` is automatically "routed" to the parent thread.
postMessage({ hello: "world" });
// On the main thread
nodeWorker.postMessage({ hello: "world" });
// ...some time later
nodeWorker.terminate();
// Bun.pathToFileURL
const _worker3 = new Worker(new URL("worker.ts", import.meta.url).href, {
ref: true,
smol: true,
credentials: "",
name: "a name",
env: {
envValue: "hello",
},
});
export { nodeWorker as worker, _worker2, _worker3 };
|
