[poolifier.git] / examples / typescript / pool.ts

import { join } from 'path'
import { DynamicThreadPool, FixedThreadPool } from 'poolifier'
import type { MyData, MyResponse } from './worker'

export const fixedPool = new FixedThreadPool<MyData, Promise<MyResponse>>(
  8,
  join(__dirname, 'worker.js'),
  {
    errorHandler: (e: Error) => console.error(e),
    onlineHandler: () => console.log('Worker is online')
  }
)

export const dynamicPool = new DynamicThreadPool<MyData, Promise<MyResponse>>(
  2,
  8,
  join(__dirname, 'worker.js'),
  {
    errorHandler: (e: Error) => console.error(e),
    onlineHandler: () => console.log('Worker is online')
  }
)
Commit	Line	Data
	1	import { join } from 'path'
	2	import { DynamicThreadPool, FixedThreadPool } from 'poolifier'
	3	import type { MyData, MyResponse } from './worker'
	4
	5	export const fixedPool = new FixedThreadPool<MyData, Promise<MyResponse>>(
	6	8,
	7	join(__dirname, 'worker.js'),
	8	{
	9	errorHandler: (e: Error) => console.error(e),
	10	onlineHandler: () => console.log('Worker is online')
	11	}
	12	)
	13
	14	export const dynamicPool = new DynamicThreadPool<MyData, Promise<MyResponse>>(
	15	2,
	16	8,
	17	join(__dirname, 'worker.js'),
	18	{
	19	errorHandler: (e: Error) => console.error(e),
	20	onlineHandler: () => console.log('Worker is online')
	21	}
	22	)