examples/typescript/smtp-client-pool/src/pool.ts

   1 import { dirname, extname, join } from 'node:path'
   2 import { fileURLToPath } from 'node:url'
   3
   4 import type SMTPTransport from 'nodemailer/lib/smtp-transport/index.js'
   5 import { availableParallelism, DynamicThreadPool } from 'poolifier'
   6
   7 import type { WorkerData } from './types.js'
   8
   9 const workerFile = join(
  10   dirname(fileURLToPath(import.meta.url)),
  11   `worker${extname(fileURLToPath(import.meta.url))}`
  12 )
  13
  14 export const smtpClientPool = new DynamicThreadPool<
  15 WorkerData,
  16 SMTPTransport.SentMessageInfo
  17 >(0, availableParallelism(), workerFile, {
  18   enableTasksQueue: true,
  19   tasksQueueOptions: {
  20     concurrency: 8
  21   },
  22   errorHandler: (e: Error) => {
  23     console.error('Thread worker error:', e)
  24   }
  25 })