murm/mrmBot-Matrix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Removed unnecessary message to main thread

Browse source
This commit is contained in:
TheEssem 2021-01-04 17:33:13 -06:00
parent 87e2e56ef0
commit 10ee3c6a31
1 changed files with 0 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

9
api/index.js
View file

@ -56,14 +56,6 @@ if (isMainThread) {
const worker = new Worker(__filename); const worker = new Worker(__filename);
log(`Spawned worker ${uuid}`); log(`Spawned worker ${uuid}`);
queue.shift(); queue.shift();
worker.once("message", (uuid) => {
// This means the worker is finished
workingWorkers--;
if (queue.length > 0) {
acceptJob(queue[0]); // Get the next job UUID in queue and remove it from the original queue
delete jobs[uuid];
}
});
worker.once("error", err => { worker.once("error", err => {
console.error(`Error on worker ${uuid}:`, err); console.error(`Error on worker ${uuid}:`, err);
socket.send(Buffer.concat([Buffer.from([0x2]), Buffer.from(uuid), Buffer.from(err.toString())]), jobs[uuid].port, jobs[uuid].addr); socket.send(Buffer.concat([Buffer.from([0x2]), Buffer.from(uuid), Buffer.from(err.toString())]), jobs[uuid].port, jobs[uuid].addr);
@ -179,6 +171,5 @@ if (isMainThread) {
socket.send(Buffer.concat([Buffer.from([0x1]), Buffer.from(job.uuid), Buffer.from(job.port.toString())]), job.port, job.addr, () => { socket.send(Buffer.concat([Buffer.from([0x1]), Buffer.from(job.uuid), Buffer.from(job.port.toString())]), job.port, job.addr, () => {
socket.close(); socket.close();
}); });
parentPort.postMessage(job.uuid); //Inform main thread about this worker freeing up
}); });
} }