TaskController::runTasks() - Code Metrics - Inspection of "Initial commit" - Yoshi2889/tasks - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — master (eb5e46)

by Rick

created 2017-07-10 16:02 UTC

TaskController::runTasks() A

↳ Parent: TaskController

Complexity

Conditions	4
Paths	4

Size

Total Lines	16
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	16
rs	9.2
c	0
b	0
f	0
cc	4
eloc	8
nc	4
nop	0

<?php

/**
 * Copyright 2017 NanoSector
 *
 * You should have received a copy of the MIT license with the project.
 * See the LICENSE file for more information.
 */

namespace Yoshi2889\Tasks;

use React\EventLoop\LoopInterface;

class TaskController
{
	/**
	 * @var int
	 */
	protected $loopInterval = 1;

	/**
	 * @var TaskInterface[]
	 */
	protected $tasks = [];

	/**
	 * TaskController constructor.
	 *
	 * @param LoopInterface $loop
	 */
	public function __construct(LoopInterface $loop)
	{
		$loop->addPeriodicTimer($this->loopInterval, [$this, 'runTasks']);
	}

	/**
	 * @param TaskInterface $task
	 *
	 * @return bool
	 */
	public function add(TaskInterface $task): bool
	{
		if ($this->exists($task))
			return false;

		$this->tasks[] = $task;

		return true;
	}

	/**
	 * @param TaskInterface $task
	 *
	 * @return bool
	 */
	public function remove(TaskInterface $task): bool
	{
		if (!$this->exists($task))
			return false;

		unset($this->tasks[array_search($task, $this->tasks)]);

		return true;
	}

	/**
	 * @param TaskInterface $task
	 *
	 * @return bool
	 */
	public function exists(TaskInterface $task): bool
	{
		return in_array($task, $this->tasks);
	}

	public function runTasks()
	{
		foreach ($this->tasks as $task)
		{
			if (time() < $task->getExpiryTime())
				continue;

			$result = $task->run();

			// It is removed first.
			$this->remove($task);

			if ($result instanceof TaskInterface)
				$this->add($result);
		}
	}
}

1			<?php
2
3			/**
4			* Copyright 2017 NanoSector
5			*
6			* You should have received a copy of the MIT license with the project.
7			* See the LICENSE file for more information.
8			*/
9
10			namespace Yoshi2889\Tasks;
11
12			use React\EventLoop\LoopInterface;
13
14			class TaskController
15			{
16			/**
17			* @var int
18			*/
19			protected $loopInterval = 1;
20
21			/**
22			* @var TaskInterface[]
23			*/
24			protected $tasks = [];
25
26			/**
27			* TaskController constructor.
28			*
29			* @param LoopInterface $loop
30			*/
31			public function __construct(LoopInterface $loop)
32			{
33			$loop->addPeriodicTimer($this->loopInterval, [$this, 'runTasks']);
34			}
35
36			/**
37			* @param TaskInterface $task
38			*
39			* @return bool
40			*/
41			public function add(TaskInterface $task): bool
42			{
43			if ($this->exists($task))
44			return false;
45
46			$this->tasks[] = $task;
47
48			return true;
49			}
50
51			/**
52			* @param TaskInterface $task
53			*
54			* @return bool
55			*/
56			public function remove(TaskInterface $task): bool
57			{
58			if (!$this->exists($task))
59			return false;
60
61			unset($this->tasks[array_search($task, $this->tasks)]);
62
63			return true;
64			}
65
66			/**
67			* @param TaskInterface $task
68			*
69			* @return bool
70			*/
71			public function exists(TaskInterface $task): bool
72			{
73			return in_array($task, $this->tasks);
74			}
75
76			public function runTasks()
77			{
78			foreach ($this->tasks as $task)
79			{
80			if (time() < $task->getExpiryTime())
81			continue;
82
83			$result = $task->run();
84
85			// It is removed first.
86			$this->remove($task);
87
88			if ($result instanceof TaskInterface)
89			$this->add($result);
90			}
91			}
92			}

Yoshi2889 / tasks

Branch — master (eb5e46)

TaskController::runTasks() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like