Carno\Coroutine\Scheduled\PQJobs

Complexity

Total Complexity

4

Size/Duplication

Total Lines	34
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	dequeue()	0	3	1
A	compare()	0	3	1
A	enqueue()	0	3	1
A	__construct()	0	3	1

<?php
/**
 * Priority queue for jobs
 * User: moyo
 * Date: 06/08/2017
 * Time: 2:47 PM
 */

namespace Carno\Coroutine\Scheduled;

use Carno\Coroutine\Job;
use SplPriorityQueue;

class PQJobs extends SplPriorityQueue
{
    /**
     * PQJobs constructor.
     */
    public function __construct()
    {
        $this->setExtractFlags(self::EXTR_DATA);
    }

    /**
     * @param mixed $priority1
     * @param mixed $priority2
     * @return int
     */
    public function compare($priority1, $priority2) : int
    {
        return $priority2 <=> $priority1;
    }

    /**
     * @param Job $job
     */
    public function enqueue(Job $job) : void
    {
        $this->insert($job, $job->priority());
    }

    /**
     * @return Job
     */
    public function dequeue() : Job
    {
        return $this->extract();
    }
}