Method push

lib/cluster/DelayQueue.ts:25–42

* Add a new item to the queue * * @param bucket bucket name * @param item function that will run later * @param options

(bucket: string, item: Function, options: DelayQueueOptions)

   * @param options
   */
  push(bucket: string, item: Function, options: DelayQueueOptions): void {
    const callback = options.callback || process.nextTick;
    if (!this.queues[bucket]) {
      this.queues[bucket] = new Deque();
    }

    const queue = this.queues[bucket];
    queue.push(item);

    if (!this.timeouts[bucket]) {
      this.timeouts[bucket] = setTimeout(() => {
        callback(() => {
          this.timeouts[bucket] = null;
          this.execute(bucket);
        });
      }, options.timeout);
    }
  }

  private execute(bucket: string): void {
    const queue = this.queues[bucket];