examples/typescript/http-server-pool/express-worker_threads/src/pool.ts

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