queue method

void queue(
  1. BurstRunner r
)
override

Implementation

void queue(BurstRunner r) {
  if (isClosed()) {
    throw new Exception("Already closed");
  }

  Completer<void> c = Completer();
  Thread t = threads[_cursor++ % threads.length];
  t.emit("q", r);
  t.once("k", (data) => c.complete());
  _queues.add(c.future);
}