consumerpollingtrait.php

<?php
 
namespace Bitrix\Calendar\Core\Queue\Impl;
 
use Bitrix\Calendar\Core\Queue\Interfaces;
 
trait ConsumerPollingTrait
{
    protected int $pollingInterval = 1000;
 
    public function setPollingInterval(int $msec): self
    {
        $this->pollingInterval = $msec;
        return $this;
    }
 
    public function getPollingInterval(): int
    {
        return $this->pollingInterval;
    }
 
    public function receive(int $timeout = 0): ?Interfaces\Message
    {
        $timeout *= 1000; // from milliseconds to microseconds
        $startAt = microtime(true);
 
        while(true)
        {
            $message = $this->receiveNoWait();
 
            if($message)
            {
                return $message;
            }
 
            if($timeout)
            {
 
                $timeSpent = microtime(true) - $startAt;
                $timeSpent *= 1000000; // from seconds to microseconds
                $timeLeft = $timeout - $timeSpent;
 
                // No time left to wait
                if($timeLeft <= 0)
                {
                    return null;
                }
 
                // We pay attention not to wait too long to go over the timeout limit
                $sleep = min($timeLeft, $this->pollingInterval * 1000);
 
            }
            else
            {
                $sleep = $this->pollingInterval * 1000;
            }
 
            usleep((int)$sleep);
        }
    }
}