X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=examples%2Ftypescript%2Fpool.ts;h=fb48f7b07db76324a75afc001e131dd448a6809f;hb=fbcf5e158672b78b5c495f30df86699a1b2360d4;hp=c55c4e96557dc8fcb400847745b0ac2c5ee014c7;hpb=cda9d69ed44d1507db8796f4469f70f669c012b6;p=poolifier.git diff --git a/examples/typescript/pool.ts b/examples/typescript/pool.ts index c55c4e96..fb48f7b0 100644 --- a/examples/typescript/pool.ts +++ b/examples/typescript/pool.ts @@ -14,7 +14,7 @@ const workerFile = join( `worker${extname(fileURLToPath(import.meta.url))}` ) -export const fixedPool = new FixedThreadPool( +const fixedPool = new FixedThreadPool( availableParallelism(), workerFile, { @@ -27,7 +27,9 @@ export const fixedPool = new FixedThreadPool( } ) -export const dynamicPool = new DynamicThreadPool( +await fixedPool.execute() + +const dynamicPool = new DynamicThreadPool( Math.floor(availableParallelism() / 2), availableParallelism(), workerFile, @@ -41,6 +43,8 @@ export const dynamicPool = new DynamicThreadPool( } ) +await dynamicPool.execute() + // eslint-disable-next-line @typescript-eslint/no-misused-promises setTimeout(async () => { await fixedPool.destroy()