examples/typescript/http-client/src/pool.ts

   1 import { fileURLToPath } from 'node:url'
   2 import { dirname, extname, join } from 'node:path'
   3 import { FixedThreadPool, availableParallelism } from 'poolifier'
   4 import { type WorkerData, type WorkerResponse } from './types.js'
   5
   6 const workerFile = join(
   7   dirname(fileURLToPath(import.meta.url)),
   8   `worker${extname(fileURLToPath(import.meta.url))}`
   9 )
  10
  11 export const httpClientPool = new FixedThreadPool<WorkerData, WorkerResponse>(
  12   availableParallelism(),
  13   workerFile,
  14   {
  15     enableTasksQueue: true,
  16     tasksQueueOptions: {
  17       concurrency: 8
  18     },
  19     errorHandler: (e: Error) => {
  20       console.error(e)
  21     }
  22   }
  23 )