examples/typescript/http-server-pool/express-hybrid/src/main.ts

   1 import { dirname, extname, join } from 'node:path'
   2 import { fileURLToPath } from 'node:url'
   3
   4 import { availableParallelism, FixedClusterPool } from 'poolifier'
   5
   6 import type { ClusterWorkerData, ClusterWorkerResponse } from './types.js'
   7
   8 const expressWorkerFile = join(
   9   dirname(fileURLToPath(import.meta.url)),
  10   `express-worker${extname(fileURLToPath(import.meta.url))}`
  11 )
  12
  13 const requestHandlerWorkerFile = join(
  14   dirname(fileURLToPath(import.meta.url)),
  15   `request-handler-worker${extname(fileURLToPath(import.meta.url))}`
  16 )
  17
  18 const pool = new FixedClusterPool<ClusterWorkerData, ClusterWorkerResponse>(
  19   availableParallelism(),
  20   expressWorkerFile,
  21   {
  22     enableEvents: false,
  23     onlineHandler: () => {
  24       pool
  25         .execute({
  26           port: 8080,
  27           maxWorkers:
  28             Math.round(availableParallelism() / 4) < 1
  29               ? 1
  30               : Math.round(availableParallelism() / 4),
  31           workerFile: requestHandlerWorkerFile,
  32           enableTasksQueue: true,
  33           tasksQueueOptions: {
  34             concurrency: 8,
  35           },
  36           errorHandler: (e: Error) => {
  37             console.error('Thread worker error:', e)
  38           },
  39         })
  40         .then(response => {
  41           if (response.status) {
  42             console.info(
  43               // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
  44               `Express is listening in cluster worker on port ${response.port?.toString()}`
  45             )
  46           }
  47           return undefined
  48         })
  49         .catch((error: unknown) => {
  50           console.error('Express failed to start in cluster worker:', error)
  51         })
  52     },
  53     errorHandler: (e: Error) => {
  54       console.error('Cluster worker error:', e)
  55     },
  56   }
  57 )