0f96a313d503b96a518b494fe2de7083798faf1a
1 import { dirname
, extname
, join
} from
'node:path'
2 import { fileURLToPath
} from
'node:url'
4 import { availableParallelism
, FixedClusterPool
} from
'poolifier'
6 import type { ClusterWorkerData
, ClusterWorkerResponse
} from
'./types.js'
8 const expressWorkerFile
= join(
9 dirname(fileURLToPath(import.meta
.url
)),
10 `express-worker${extname(fileURLToPath(import.meta.url))}`
13 const requestHandlerWorkerFile
= join(
14 dirname(fileURLToPath(import.meta
.url
)),
15 `request-handler-worker${extname(fileURLToPath(import.meta.url))}`
18 const pool
= new FixedClusterPool
<ClusterWorkerData
, ClusterWorkerResponse
>(
19 availableParallelism(),
23 onlineHandler
: () => {
28 Math.round(availableParallelism() / 4) < 1
30 : Math.round(availableParallelism() / 4),
31 workerFile
: requestHandlerWorkerFile
,
32 enableTasksQueue
: true,
36 errorHandler
: (e
: Error) => {
37 console
.error('Thread worker error:', e
)
41 if (response
.status) {
43 `Express is listening in cluster worker on port ${response.port}`
49 console
.error('Express failed to start in cluster worker:', error
)
52 errorHandler
: (e
: Error) => {
53 console
.error('Cluster worker error:', e
)