examples/typescript/pool.ts

   1 import { dirname, extname, join } from 'node:path'
   2 import { fileURLToPath } from 'node:url'
   3 import {
   4   availableParallelism,
   5   DynamicThreadPool,
   6   FixedThreadPool,
   7 } from 'poolifier'
   8
   9 import type { MyData, MyResponse } from './worker.js'
  10
  11 const workerFile = join(
  12   dirname(fileURLToPath(import.meta.url)),
  13   `worker${extname(fileURLToPath(import.meta.url))}`
  14 )
  15
  16 const fixedPool = new FixedThreadPool<MyData, MyResponse>(
  17   availableParallelism(),
  18   workerFile,
  19   {
  20     errorHandler: (e: Error) => {
  21       console.error(e)
  22     },
  23     onlineHandler: () => {
  24       console.info('Worker is online')
  25     },
  26   }
  27 )
  28
  29 await fixedPool.execute()
  30
  31 const dynamicPool = new DynamicThreadPool<MyData, MyResponse>(
  32   Math.floor(availableParallelism() / 2),
  33   availableParallelism(),
  34   workerFile,
  35   {
  36     errorHandler: (e: Error) => {
  37       console.error(e)
  38     },
  39     onlineHandler: () => {
  40       console.info('Worker is online')
  41     },
  42   }
  43 )
  44
  45 await dynamicPool.execute()
  46
  47 // eslint-disable-next-line @typescript-eslint/no-misused-promises
  48 setTimeout(async () => {
  49   await fixedPool.destroy()
  50   await dynamicPool.destroy()
  51 }, 3000)