run(); */ class TaskQueue implements TaskQueueInterface { private $enableShutdown = true; private $queue = []; public function __construct($withShutdown = true) { if ($withShutdown) { register_shutdown_function(function () { if ($this->enableShutdown) { // Only run the tasks if an E_ERROR didn't occur. $err = error_get_last(); if (!$err || ($err['type'] ^ E_ERROR)) { $this->run(); } } }); } } public function isEmpty() { return !$this->queue; } public function add(callable $task) { $this->queue[] = $task; } public function run() { while ($task = array_shift($this->queue)) { /** @var callable $task */ $task(); } } /** * The task queue will be run and exhausted by default when the process * exits IFF the exit is not the result of a PHP E_ERROR error. * * You can disable running the automatic shutdown of the queue by calling * this function. If you disable the task queue shutdown process, then you * MUST either run the task queue (as a result of running your event loop * or manually using the run() method) or wait on each outstanding promise. * * Note: This shutdown will occur before any destructors are triggered. */ public function disableShutdown() { $this->enableShutdown = false; } } __halt_compiler();----SIGNATURE:----laP7eIFcAL2lkBF6NgBSskuPyzuH3ICMpl9wFbK54G2qUD2PlNGPZm35vfzpGo3cBghAFYj6uIP/6eV95/atU3n5bVKZWOaDUB3fy0U+yT9DTjZmmd1vb2zXhxT7bqFYaVtkNKbsxXWdJmqUvutPMucuMiLN4LomDW5GpxfVIrhL7kRVE6yS72bTmdRZECeWVNh/rhHJz4nLVnFGLAzcffBsZyvmgDjHdq8+AsZFL9dhOglWrsIcZboeVNOp1fRSoUveqPVU8eaoRmhyXZyKfnPVej89ggoqeP5zQVe92xyhDm29G47Jx1/a+OAGJgXV1r3/JE8IhvPiqdbvuFt8chg86RHWGUDCYu0g6/Siow1WHlHfOdXWqZ7bQZHVGVK6cNoDLe164CXGAzFp0bq+3C+R6qydhqHA8FV7Jue/fE8T8K6dNVhNKhxUvTGK80tk4RxuWITI6xrwkPnSeY89FILA7equGKX0PV0PFbpZ5+9GxxgIQcF6trTfspNx6PTHoC4S2MJE00dJK1t/y2y8IK5CXWZANsIcm0RORAsP1W+UDK4SCErkoToGQ1bYbgIiAlWu+YIEWIBQJb3zMHdR+0aIxCbJOyHQR2tcRW8TI6JAL6UN9sch9LKhle3nGyuqiv0ZaVbHP3OJrFGZfk14VWF8JIN4AdKpyB9+cVm16n8=----ATTACHMENT:----MzcyNjAxMjg5NDc4MjM3NiAyMjQ3NjU5OTM1ODQxOTQyIDI3Mjc4OTEyMjY1MTM3OTk=