6988372eb1e4e07683fd129f8a2ea2b9ea0d40e2
1 import { dirname
, extname
, join
} from
'node:path'
2 import { fileURLToPath
} from
'node:url'
4 import { availableParallelism
, DynamicThreadPool
} from
'poolifier'
6 import type { WorkerData
, WorkerResponse
} from
'./types.js'
8 const workerFile
= join(
9 dirname(fileURLToPath(import.meta
.url
)),
10 `worker${extname(fileURLToPath(import.meta.url))}`
13 export const httpClientPool
= new DynamicThreadPool
<WorkerData
, WorkerResponse
>(
15 availableParallelism(),
18 enableTasksQueue
: true,
22 errorHandler
: (e
: Error) => {
23 console
.error('Thread worker error:', e
)