Method drain

packages/core/src/threading/Thread.ts:180–183

(callback: (task: ThreadGenerator) => void)

  }

  public drain(callback: (task: ThreadGenerator) => void) {
    this.queue.forEach(callback);
    this.queue = [];
  }

  public cancel() {
    this.runner.return();