docs: document availableParallelism() usage
[poolifier.git] / examples / typescript / pool.ts
index 869e62a8bf718020c155ae221b85921735a61d74..b6bb4da3427a93132842e5953cd6fa858d52408d 100644 (file)
@@ -1,9 +1,13 @@
 import { join } from 'path'
 import type { MyData, MyResponse } from './worker'
-import { DynamicThreadPool, FixedThreadPool } from 'poolifier'
+import {
+  DynamicThreadPool,
+  FixedThreadPool,
+  availableParallelism
+} from 'poolifier'
 
 export const fixedPool = new FixedThreadPool<MyData, Promise<MyResponse>>(
-  8,
+  availableParallelism(),
   join(__dirname, 'worker.js'),
   {
     errorHandler: (e: Error) => {
@@ -16,8 +20,8 @@ export const fixedPool = new FixedThreadPool<MyData, Promise<MyResponse>>(
 )
 
 export const dynamicPool = new DynamicThreadPool<MyData, Promise<MyResponse>>(
-  2,
-  8,
+  availableParallelism() / 2,
+  availableParallelism(),
   join(__dirname, 'worker.js'),
   {
     errorHandler: (e: Error) => {