PQJobs::dequeue()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 3
Code Lines 1

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 1
Metric Value
cc 1
eloc 1
c 1
b 0
f 1
nc 1
nop 0
dl 0
loc 3
rs 10
1
<?php
2
/**
3
 * Priority queue for jobs
4
 * User: moyo
5
 * Date: 06/08/2017
6
 * Time: 2:47 PM
7
 */
8
9
namespace Carno\Coroutine\Scheduled;
10
11
use Carno\Coroutine\Job;
12
use SplPriorityQueue;
13
14
class PQJobs extends SplPriorityQueue
15
{
16
    /**
17
     * PQJobs constructor.
18
     */
19
    public function __construct()
20
    {
21
        $this->setExtractFlags(self::EXTR_DATA);
22
    }
23
24
    /**
25
     * @param mixed $priority1
26
     * @param mixed $priority2
27
     * @return int
28
     */
29
    public function compare($priority1, $priority2) : int
30
    {
31
        return $priority2 <=> $priority1;
32
    }
33
34
    /**
35
     * @param Job $job
36
     */
37
    public function enqueue(Job $job) : void
38
    {
39
        $this->insert($job, $job->priority());
40
    }
41
42
    /**
43
     * @return Job
44
     */
45
    public function dequeue() : Job
46
    {
47
        return $this->extract();
48
    }
49
}
50