- const threadWorker = new Worker('./tests/worker-files/thread/testWorker.mjs')
- const clusterWorker = cluster.fork()
- const threadWorkerNode = new WorkerNode(threadWorker, 12)
- const clusterWorkerNode = new WorkerNode(clusterWorker, 12)
+ const threadWorkerNode = new WorkerNode(
+ WorkerTypes.thread,
+ './tests/worker-files/thread/testWorker.mjs',
+ { tasksQueueBackPressureSize: 12 }
+ )
+ const clusterWorkerNode = new WorkerNode(
+ WorkerTypes.cluster,
+ './tests/worker-files/cluster/testWorker.cjs',
+ { tasksQueueBackPressureSize: 12 }
+ )