1 import type { CircularArray
} from
'../circular-array'
4 * Callback invoked if the worker has received a message.
6 export type MessageHandler
<Worker
extends IWorker
> = (
12 * Callback invoked if the worker raised an error.
14 export type ErrorHandler
<Worker
extends IWorker
> = (
20 * Callback invoked when the worker has started successfully.
22 export type OnlineHandler
<Worker
extends IWorker
> = (this: Worker
) => void
25 * Callback invoked when the worker exits successfully.
27 export type ExitHandler
<Worker
extends IWorker
> = (
33 * Worker task interface.
35 export interface Task
<Data
= unknown
> {
41 * Worker tasks usage statistics.
43 export interface TasksUsage
{
47 runTimeHistory
: CircularArray
<number>
56 export interface IWorker
{
58 * Register an event listener.
60 * @param event - The event.
61 * @param handler - The event listener.
63 on
: ((event
: 'message', handler
: MessageHandler
<this>) => void) &
64 ((event
: 'error', handler
: ErrorHandler
<this>) => void) &
65 ((event
: 'online', handler
: OnlineHandler
<this>) => void) &
66 ((event
: 'exit', handler
: ExitHandler
<this>) => void)
68 * Register a listener to the exit event that will only performed once.
70 * @param event - `'exit'`.
71 * @param handler - The exit handler.
73 once
: (event
: 'exit', handler
: ExitHandler
<this>) => void
77 * Worker node interface.
79 export interface WorkerNode
<Worker
extends IWorker
, Data
= unknown
> {
81 tasksUsage
: TasksUsage
82 tasksQueue
: Array<Task
<Data
>>