We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9d3d29b commit 46f2f28Copy full SHA for 46f2f28
index.js
@@ -1,5 +1,6 @@
1
'use strict';
2
const crypto = require('crypto');
3
+const path = require('path');
4
5
const requireOptional = (name, defaultValue) => {
6
try {
@@ -11,12 +12,14 @@ const requireOptional = (name, defaultValue) => {
11
12
13
const {Worker} = requireOptional('worker_threads', {});
14
15
+const threadFilePath = path.join(__dirname, 'thread.js');
16
+
17
let worker; // Lazy
18
let taskIdCounter = 0;
19
const tasks = new Map();
20
21
const createWorker = () => {
- worker = new Worker('./thread.js');
22
+ worker = new Worker(threadFilePath);
23
worker.on('message', message => {
24
const task = tasks.get(message.id);
25
tasks.delete(message.id);
0 commit comments