NESTJS.md

nestjs integration example

The integration in nestjs is as simple as possible, in your service / controller delegate the work to the worker threads.

• nestjs integration example
  • Worker
  • Controller
  • Main

Worker

@WP.ThreadLoad()
@Injectable()
export class Work {
   public doWork(timeout:number): Promise<string> {
      return new Promise((resolve) => setTimeout(resolve, timeout)).then(() => 'Done Work.');
   }
}

Controller

@Controller()
export class AppController {
  @Get()
  getHello(@Query('t') timeout = 1000): Promise<string> {
    const work = WP.Create<Work>(Work);
    return work.doWork(+timeout);
  }
}

Second option is to register the Work as a service and inject that into the controller. For this option to work, we need to be carefull on how we register the provider. We can't create / proxify the class directly in the 'providers' property. We need to delay the creation until the Pool has started.

@Module({
  imports: [],
  controllers: [AppController],
  providers: [{
    provide: Work,
    useFactory: () => WP.Create(Work)
  }]
})
export class AppModule {}

Use the service

@Controller()
export class AppController {
  constructor(private readonly work: Work){}
  @Get()
  getHello(@Query('t') timeout = 1000): Promise<string> {
    // Queue work on the worker threads.
    return this.work.doWork(+timeout);
  }
}

Main

async function bootstrap() {
  WP.Threading.initialize();
  const app = await NestFactory.create(AppModule);
  await app.listen(3000);
}
bootstrap();