Basic worker thread pool in Feathers, using threads.js

jobs.class.ts

import {Id, NullableId, Paginated, Params, ServiceMethods, SetupMethod} from '@feathersjs/feathers';
import {App} from '../../app.interface'
import {isWorkerRuntime, Pool, spawn, Thread, Worker} from "threads";
import {JobWorker} from "./jobWorker";

interface ServiceOptions {}

export class Jobs implements ServiceMethods<Data>, SetupMethod {
  app: App;
  options: ServiceOptions;

  workerPool: Pool<JobWorker & Thread> | undefined

  constructor (options: ServiceOptions = {}, app: App) {
    this.options = options;
    this.app = app;
  }

  setup(app: App, path: string): void {
    this.workerPool = Pool<JobWorker & Thread>(() => spawn<JobWorker>(new Worker("./jobWorker")), 8)
  }

  async create (data: Data, params?: Params): Promise<Data> {
    const testTask = this.workerPool?.queue(jobWorker => jobWorker.doMyJob())
    testTask?.then(() => {
      // do something after the job finishes
    })
  
    return data;
  }
}

jobWorker.ts

import { expose } from "threads/worker"

const jobWorker = {
  async doMyJob() {
    console.log('Hello from worker thread!')
  }
}

export type JobWorker = typeof jobWorker
expose(jobWorker)