SyncPromiseQueue.php — WooCommerce 10.9.4

woocommerce / lib / packages / GraphQL / Executor / Promise / Adapter / SyncPromiseQueue.php

woocommerce / lib / packages / GraphQL / Executor / Promise / Adapter Last commit date

SyncPromiseQueue.php

75 lines

1	<?php declare(strict_types=1);
2
3	namespace Automattic\WooCommerce\Vendor\GraphQL\Executor\Promise\Adapter;
4
5	/**
6	* Queue for deferred execution of SyncPromise tasks.
7	*
8	* Owns the shared queue and provides the run loop for processing promises.
9	*
10	* @api
11	*
12	* @phpstan-type Task callable(): void
13	*/
14	class SyncPromiseQueue
15	{
16	/**
17	* Adds a task to the queue.
18	*
19	* @param Task $task
20	*
21	* @api
22	*/
23	public static function enqueue(callable $task): void
24	{
25	self::queue()->enqueue($task);
26	}
27
28	/**
29	* Process all queued promises until the queue is empty.
30	*
31	* @api
32	*/
33	public static function run(): void
34	{
35	$queue = self::queue();
36	while (! $queue->isEmpty()) {
37	$task = $queue->dequeue();
38	$task();
39	}
40	}
41
42	/**
43	* Check if the queue is empty.
44	*
45	* @api
46	*/
47	public static function isEmpty(): bool
48	{
49	return self::queue()->isEmpty();
50	}
51
52	/**
53	* Return the number of tasks in the queue.
54	*
55	* @api
56	*/
57	public static function count(): int
58	{
59	return self::queue()->count();
60	}
61
62	/**
63	* TODO change to protected in next major version.
64	*
65	* @return \SplQueue<Task>
66	*/
67	public static function queue(): \SplQueue
68	{
69	/** @var \SplQueue<Task>\|null $queue */
70	static $queue;
71
72	return $queue ??= new \SplQueue();
73	}
74	}
75