Dazzle\Loop\Timer\TimerBox

Complexity

Total Complexity

17

Size/Duplication

Total Lines	141
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

97.92%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	updateTime()	0	4	1
A	getTime()	0	4	2
A	contains()	0	4	1
A	add()	0	8	1
A	remove()	0	4	1
A	getFirst()	0	16	3
A	isEmpty()	0	4	1
B	tick()	0	38	6

<?php

namespace Dazzle\Loop\Timer;

use SplObjectStorage;
use SplPriorityQueue;

class TimerBox
{
    /**
     * @var float
     */
    protected $time;

    /**
     * @var SplObjectStorage
     */
    protected $timers;

    /**
     * @var SplPriorityQueue
     */
    protected $scheduler;

    /**
     *
     */
    public function __construct()
    {
        $this->timers = new SplObjectStorage();
        $this->scheduler = new SplPriorityQueue();
    }

    /**
     * @return float
     */
    public function updateTime()
    {
        return $this->time = microtime(true);
    }

    /**
     * @return mixed
     */
    public function getTime()
    {
        return $this->time ?: $this->updateTime();
    }

    /**
     * @param TimerInterface $timer
     * @return bool
     */
    public function contains(TimerInterface $timer)
    {
        return $this->timers->contains($timer);
    }

    /**
     * @param TimerInterface $timer
     */
    public function add(TimerInterface $timer)
    {
        $interval = $timer->getInterval();
        $scheduledAt = $interval + $this->getTime();

        $this->timers->attach($timer, $scheduledAt);
        $this->scheduler->insert($timer, -$scheduledAt);
    }

    /**
     * @param TimerInterface $timer
     */
    public function remove(TimerInterface $timer)
    {
        $this->timers->detach($timer);
    }

    /**
     * @return TimerInterface|null
     */
    public function getFirst()
    {
        while ($this->scheduler->count())
        {
            $timer = $this->scheduler->top();

            if ($this->timers->contains($timer))
            {
                return $this->timers[$timer];
            }

            $this->scheduler->extract();
        }

        return null;
    }

    /**
     * @return bool
     */
    public function isEmpty()
    {
        return count($this->timers) === 0;
    }

    /**
     *
     */
    public function tick()
    {
        $time = $this->updateTime();
        $timers = $this->timers;
        $scheduler = $this->scheduler;

        while (!$scheduler->isEmpty())
        {
            $timer = $scheduler->top();

            if (!isset($timers[$timer]))
            {
                $scheduler->extract();
                $timers->detach($timer);
                continue;
            }

            if ($timers[$timer] >= $time)
            {
                break;
            }

            $scheduler->extract();

            $callback = $timer->getCallback();
            $callback($timer);

            if ($timer->isPeriodic() && isset($timers[$timer]))
            {
                $timers[$timer] = $scheduledAt = $timer->getInterval() + $time;
                $scheduler->insert($timer, -$scheduledAt);
            }
            else
            {
                $timers->detach($timer);
            }
        }
    }
}