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 960be7c commit 45dfea8Copy full SHA for 45dfea8
src/lib/workers/test-workers.ts
@@ -1,12 +1,10 @@
1
-import * as os from 'os';
2
import process from 'process';
3
import { Pool, spawn, Worker } from 'threads';
4
5
async function testWorkers() {
6
process.stdout.write('Lets test workers.\n');
7
- const coreCount = os.cpus().length;
8
- const pool = Pool(() => spawn(new Worker('./worker')), coreCount);
9
- for (let i = 0; i < coreCount; i++) {
+ const pool = Pool(() => spawn(new Worker('./worker')), 1);
+ for (let i = 0; i < 1; i++) {
10
void pool.queue(async (hellower) => {
11
process.stdout.write((await hellower.helloWorld()) + '\n');
12
});
0 commit comments