import { ThreadWorker } from 'poolifier'
export interface MyData {
- ok: number
+ ok: 0 | 1
}
export interface MyResponse {
class MyThreadWorker extends ThreadWorker<MyData, Promise<MyResponse>> {
constructor () {
- super(data => this.process(data), {
- maxInactiveTime: 60_000,
- async: true
+ super(async (data: MyData) => await this.process(data), {
+ maxInactiveTime: 60000
})
}
private async process (data: MyData): Promise<MyResponse> {
- return new Promise(resolve => {
+ return await new Promise(resolve => {
setTimeout(() => {
resolve({ message: 'Hello from Worker :)', data })
- }, 10_000)
+ }, 10000)
})
}
}