summaryrefslogtreecommitdiffstats
path: root/vendor/ipl/stdlib/src/PriorityQueue.php
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-28 12:38:04 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-28 12:38:04 +0000
commit1ff5c35de5dbd70a782875a91dd2232fd01b002b (patch)
tree77d9ce5e1bf78b3e6ef79f8f6e7861e2ced3c09b /vendor/ipl/stdlib/src/PriorityQueue.php
parentInitial commit. (diff)
downloadicinga-php-library-upstream.tar.xz
icinga-php-library-upstream.zip
Adding upstream version 0.10.1.upstream/0.10.1upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'vendor/ipl/stdlib/src/PriorityQueue.php')
-rw-r--r--vendor/ipl/stdlib/src/PriorityQueue.php41
1 files changed, 41 insertions, 0 deletions
diff --git a/vendor/ipl/stdlib/src/PriorityQueue.php b/vendor/ipl/stdlib/src/PriorityQueue.php
new file mode 100644
index 0000000..a50b31d
--- /dev/null
+++ b/vendor/ipl/stdlib/src/PriorityQueue.php
@@ -0,0 +1,41 @@
+<?php
+
+namespace ipl\Stdlib;
+
+use Generator;
+use SplPriorityQueue;
+
+/**
+ * Stable priority queue that also maintains insertion order for items with the same priority
+ */
+class PriorityQueue extends SplPriorityQueue
+{
+ protected $serial = PHP_INT_MAX;
+
+ /**
+ * @inheritDoc
+ *
+ * Maintains insertion order for items with the same priority.
+ */
+ public function insert($value, $priority): bool
+ {
+ return parent::insert($value, [$priority, $this->serial--]);
+ }
+
+ /**
+ * Yield all items as priority-value pairs
+ *
+ * @return Generator
+ */
+ public function yieldAll()
+ {
+ // Clone queue because the SplPriorityQueue acts as a heap and thus items are removed upon iteration
+ $queue = clone $this;
+
+ $queue->setExtractFlags(static::EXTR_BOTH);
+
+ foreach ($queue as $item) {
+ yield $item['priority'][0] => $item['data'];
+ }
+ }
+}