class

ForkJoin::InjectionQueue

Inherits Reference < Object

Global runnable list for fibers submitted by bare threads or other contexts.

Instance methods

empty?
Source
push(fiber : Fiber) : Bool

Returns true when this publication transitions the queue from empty to nonempty and therefore needs to activate workers.

Source
push_batch(fibers : Pointer(Fiber), count : Int32) : Bool
Source
shift?
Source
shift_batch(target : Pointer(Fiber), limit : Int32, workers : Int32) : Int32

Removes up to limit fibers while acquiring the injection lock once. Returns the number written into target.

Source
size
Source