Method: Polyphony::Queue#pending?

Defined in:
ext/polyphony/queue.c

#pending? ⇒ boolean

Returns true if any fibers are currently waiting to remove items from the queue.

Returns:

  • (boolean) 


385
386
387
388
389
390
 
# File 'ext/polyphony/queue.c', line 385

VALUE Queue_pending_p(VALUE self) {
  Queue_t *queue;
  GetQueue(self, queue);

  return (queue->shift_queue.count) ? Qtrue : Qfalse;
}