0b44e64042a3d58abf7de4966101633b2b9f31b7
1 import { ThreadWorker
} from
"poolifier";
3 export interface MyData
{
7 export interface MyResponse
{
12 class MyThreadWorker
extends ThreadWorker
<MyData
, Promise
<MyResponse
>> {
14 super((data
) => this.process(data
), {
15 maxInactiveTime
: 60_000
,
20 private async process(data
: MyData
): Promise
<MyResponse
> {
21 return new Promise((resolve
) => {
23 resolve({ message
: "Hello from Worker :)", data
});
29 export default new MyThreadWorker();