TimeSlicingQueue

Hierarchy

• SequentialQueue
  • TimeSlicingQueue

Index

Constructors

• constructor

Properties

• concurrency
• dependencyQueue
• protectedTime
• queueId
• running

Accessors

• clearedTasks
• remainTasks

Methods

• add
• remove
• run
• stop
• tick

Constructors

constructor

• new TimeSlicingQueue(concurrency?: number, protectedTime?: number, dependencyQueue?: SequentialQueue | TimeSlicingQueue, queueId?: string): TimeSlicingQueue

• Overrides SequentialQueue.constructor

  Parameters

  • concurrency: number = 1

  • protectedTime: number = 2

  • optionaldependencyQueue: SequentialQueue | TimeSlicingQueue

  • queueId: string = ...

  Returns TimeSlicingQueue

Properties

readonlyconcurrency

concurrency: number = 1

Inherited from SequentialQueue.concurrency

optionalreadonlydependencyQueue

dependencyQueue?: SequentialQueue | TimeSlicingQueue

Inherited from SequentialQueue.dependencyQueue

readonlyprotectedTime

protectedTime: number = 2

publicreadonlyqueueId

queueId: string = ...

Inherited from SequentialQueue.queueId

running

running: boolean = false

Accessors

clearedTasks

• get clearedTasks(): number

• Inherited from SequentialQueue.clearedTasks

  Returns number

remainTasks

• get remainTasks(): number

• Inherited from SequentialQueue.remainTasks

  Returns number

Methods

add

• add(task: SequentialTask, taskId?: string): void

• Overrides SequentialQueue.add

  Parameters

  • task: SequentialTask

  • optionaltaskId: string

  Returns void

remove

• remove(task: SequentialTask): void

• Inherited from SequentialQueue.remove

  Parameters

  • task: SequentialTask

  Returns void

run

• run(): void

• Returns void

stop

• stop(): void

• Returns void

tick

• tick(): Promise<any[]>

• Inherited from SequentialQueue.tick

  Returns Promise<any[]>