server/lib/worker/parent-process.ts

   1 import { join } from 'path'
   2 import Piscina from 'piscina'
   3 import { WORKER_THREADS } from '@server/initializers/constants'
   4 import { downloadImage } from './workers/image-downloader'
   5
   6 const downloadImagerWorker = new Piscina({
   7   filename: join(__dirname, 'workers', 'image-downloader.js'),
   8   concurrentTasksPerWorker: WORKER_THREADS.DOWNLOAD_IMAGE.CONCURRENCY,
   9   maxThreads: WORKER_THREADS.DOWNLOAD_IMAGE.MAX_THREADS
  10 })
  11
  12 function downloadImageFromWorker (options: Parameters<typeof downloadImage>[0]): Promise<ReturnType<typeof downloadImage>> {
  13   return downloadImagerWorker.run(options)
  14 }
  15
  16 export {
  17   downloadImageFromWorker
  18 }