yajsapi / Exports / executor/smartq / SmartQueue
executor/smartq.SmartQueue
Name |
|
SmartQueue
new SmartQueue(items
: Item[], retry_cnt?
: number, ...rest
: any[]): SmartQueue
Type parameters:
Name |
|
Parameters:
Name | Type | Default value |
| Item[] | - |
| number | 2 |
| any[] | - |
Returns: SmartQueue
Defined in: yajsapi/executor/smartq.ts:38
• Private
__done: any
Defined in: yajsapi/executor/smartq.ts:38
• Private
__eof: any
Defined in: yajsapi/executor/smartq.ts:37
• Private
__new_items: any
Defined in: yajsapi/executor/smartq.ts:36
• Private
_in_progress: Set<Handle>
Defined in: yajsapi/executor/smartq.ts:35
• Private
_items: null | Item[]
Defined in: yajsapi/executor/smartq.ts:33
• Private
_rescheduled_items: Set<Handle>
Defined in: yajsapi/executor/smartq.ts:34
▸ __find_rescheduled_item(consumer
: Consumer): null | Handle
Parameters:
Name | Type |
| Consumer |
Returns: null | Handle
Defined in: yajsapi/executor/smartq.ts:71
▸ __have_data(): boolean
Returns: boolean
Defined in: yajsapi/executor/smartq.ts:63
▸ close(): void
Returns: void
Defined in: yajsapi/executor/smartq.ts:50
▸ get(consumer
: Consumer, callback
: undefined | null | Function): AsyncGenerator<Handle, any, unknown>
Parameters:
Name | Type |
| Consumer |
| undefined | null | Function |
Returns: AsyncGenerator<Handle, any, unknown>
Defined in: yajsapi/executor/smartq.ts:78
▸ has_unassigned_items(): boolean
Returns: boolean
Defined in: yajsapi/executor/smartq.ts:160
▸ mark_done(handle
: Handle): Promise<void>
Parameters:
Name | Type |
| Handle |
Returns: Promise<void>
Defined in: yajsapi/executor/smartq.ts:112
▸ new_consumer(): Consumer
Returns: Consumer
Defined in: yajsapi/executor/smartq.ts:59
▸ reschedule(handle
: Handle): Promise<void>
Parameters:
Name | Type |
| Handle |
Returns: Promise<void>
Defined in: yajsapi/executor/smartq.ts:124
▸ reschedule_all(consumer
: Consumer): Promise<void>
Parameters:
Name | Type |
| Consumer |
Returns: Promise<void>
Defined in: yajsapi/executor/smartq.ts:132
▸ stats(): object
Returns: object
Defined in: yajsapi/executor/smartq.ts:146
▸ wait_until_done(): Promise<void>
Returns: Promise<void>
Defined in: yajsapi/executor/smartq.ts:154