ad-worker
npm i ad-worker
This library allows spawn threads and transfer control by name, with an isolated context, or shared data between threads.
Example
// main.js
const { MainWorker } = require("ad-worker");
const mainWorker = new MainWorker({
group: [
{ name: "test", path: "./worker.js", workerData: { ok: "ok" }, mutex: 1 },
{ name: "test_2", path: "./worker_2.js", workerDataLink: "test" },
{ name: "test_3", path: "./worker.js", workerDataLink: "test" },
],
sharedData: {
length: 1024,
type: "int32"
}
});
// Or
const mainWorker = new MainWorker({});
mainWorker.newThread({
name: "test",
path: "./worker.js",
sharedData: {
length: 1024,
type: "int32"
},
workerData: { hello: "world" }
});
mainWorker.newThread({
name: "test",
path: "./worker.js"
});
// Or
mainWorker.spawn(()=>{
console.log("New thread, in this file");
});
// worker.js
const { ChildWorker } = require("ad-worker");
const { workerData } = require("worker_threads");
const childWorker = new ChildWorker(workerData);
childWorker.setSharedData({ hello: "world" });
childWorker.sendMessage("change");
childWorker.lock(()=>{
childWorker.onMessage(msg => {
console.log(msg); // Some message
childWorker.unlock();
});
});
childWorker.onMessage(msg => {
console.log(msg);
});
childWorker.sendMessage("ok");
childWorker.close();
// main.js
mainWorker.onMessage("test", msg => {
if (msg === "change") {
mainWorker.getSharedData("test", msg => {
console.log(msg); // {hello: "world"}
})
return;
}
})
mainWorker.getSharedData("test2", msg => {
console.log(msg); // { ok: "ok" }
})
mainWorker.getSharedData("test", msg => {
console.log(msg); // { ok: "ok" }
})
3.1k Jan 5, 2023
501 Dec 30, 2022
71 Dec 14, 2022
45 Dec 15, 2022
2.5k Dec 30, 2022
5 Jan 2, 2022
4 Apr 5, 2022
49 Oct 24, 2022
3 May 18, 2022
4 May 3, 2022