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               `Express is listening in cluster worker on port ${response.port}`
  44             )
  45           }
  46           return undefined
  47         })
  48         .catch(error => {
  49           console.error('Express failed to start in cluster worker:', error)
  50         })
  51     },
  52     errorHandler: (e: Error) => {
  53       console.error('Cluster worker error:', e)
  54     }
  55   }
  56 )