FixedPool::wait() - Code Metrics - Inspection of "tests" - huyanping/simple-fork-php - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( e920d0...b06e30 )

by Hu

created 2016-08-03 07:09 UTC

FixedPool::wait() B

↳ Parent: FixedPool

Complexity

Conditions	8
Paths	9

Size

Total Lines	17
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	39.042

Importance

Changes	3
Bugs	1	Features	2

Metric	Value
c	3
b	1
f	2
dl	0
loc	17
ccs	3
cts	14
cp	0.2143
rs	7.7777
cc	8
eloc	12
nc	9
nop	2
crap	39.042

<?php
/**
 * Created by PhpStorm.
 * User: Jenner
 * Date: 2015/11/2
 * Time: 17:45
 */

namespace Jenner\SimpleFork;


/**
 * fixed pool
 *
 * @package Jenner\SimpleFork
 */
class FixedPool extends AbstractPool
{
    /**
     * @var int max process count
     */
    protected $max;

    /**
     * @param int $max
     */
    public function __construct($max = 4)
    {
        $this->max = $max;
    }

    public function execute(Process $process)
    {
        Utils::checkOverwriteRunMethod(get_class($process));

        if ($this->aliveCount() < $this->max && !$process->isStarted()) {
            $process->start();
        }
        array_push($this->processes, $process);
    }

    /**
     * wait for all process done
     *
     * @param bool $block block the master process
     * to keep the sub process count all the time
     * @param int $interval check time interval
     */
    public function wait($block = false, $interval = 100)
    {
        do {
            if ($this->isFinished()) {
                return;
            }
            parent::wait(false);
            if ($this->aliveCount() < $this->max) {
                foreach ($this->processes as $process) {
                    if ($process->isStarted()) continue;
                    $process->start();
                    if ($this->aliveCount() >= $this->max) break;
                }
            }
            $block ? usleep($interval) : null;
        } while ($block);
    }

}

1		<?php
2		/**
3		* Created by PhpStorm.
4		* User: Jenner
5		* Date: 2015/11/2
6		* Time: 17:45
7		*/
8
9		namespace Jenner\SimpleFork;
10
11
12		/**
13		* fixed pool
14		*
15		* @package Jenner\SimpleFork
16		*/
17		class FixedPool extends AbstractPool
18		{
19		/**
20		* @var int max process count
21		*/
22		protected $max;
23
24		/**
25		* @param int $max
26		*/
27	3	public function __construct($max = 4)
28		{
29	3	$this->max = $max;
30	3	}
31
32	3	public function execute(Process $process)
33		{
34	3	Utils::checkOverwriteRunMethod(get_class($process));
35
36	3	if ($this->aliveCount() < $this->max && !$process->isStarted()) {
37	3	$process->start();
38	3	}
39	3	array_push($this->processes, $process);
40	3	}
41
42		/**
43		* wait for all process done
44		*
45		* @param bool $block block the master process
46		* to keep the sub process count all the time
47		* @param int $interval check time interval
48		*/
49	3	public function wait($block = false, $interval = 100)
50		{
51		do {
52	3	if ($this->isFinished()) {
53	3	return;
54		}
55		parent::wait(false);
56		if ($this->aliveCount() < $this->max) {
57		foreach ($this->processes as $process) {
58		if ($process->isStarted()) continue;
59		$process->start();
60		if ($this->aliveCount() >= $this->max) break;
61		}
62		}
63		$block ? usleep($interval) : null;
64		} while ($block);
65		}
66
67		}

huyanping / simple-fork-php

Push — master ( e920d0...b06e30 )

FixedPool::wait() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like