phasync\Util\Collections\Queue class

Documentation

Implementation of a concurrency safe queue.

Inheritance

Implements: phasync\Interfaces\QueueInterface phasync\Interfaces\LockInterface Countable

Uses Traits: phasync\Util\LockTrait

Properties (4)

private SplQueue $queue
private ?object $lockObject
private ?Fiber $lockHolder
private int $lockDepth

Methods (7)

public __construct()

Documentation missing

public isEmpty()

Documentation missing

public enqueue()

Documentation missing

public tryDequeue()

Documentation missing

public tryPeek()

Documentation missing

public count()

Documentation missing

public lock()

Lock the implementing object while the provided Closure is invoked.

Source

src/Util/Collections/Queue.php:14-79