Paraunit\Runner\PipelineCollection

Complexity

Total Complexity

13

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	push()	0	12	3
A	hasEmptySlots()	0	10	3
A	hasRunningProcesses()	0	10	3
A	triggerProcessTermination()	0	6	2

<?php

namespace Paraunit\Runner;

use Paraunit\Process\AbstractParaunitProcess;

/**
 * Class PipelineCollection
 * @package Paraunit\Runner
 */
class PipelineCollection
{
    /** @var Pipeline[] | \SplFixedArray */
    private $pipelines;

    public function __construct(PipelineFactory $pipelineFactory, int $maxProcessNumber = 10)
    {
        $this->pipelines = new \SplFixedArray($maxProcessNumber);

It seems like new \SplFixedArray($maxProcessNumber) of type object<SplFixedArray> is incompatible with the declared type array<integer,object<Paraunit\Runner\Pipeline>> of property $pipelines.

        for ($pipelineNumber = 0; $pipelineNumber < $maxProcessNumber; $pipelineNumber++) {
            $this->pipelines->offsetSet($pipelineNumber, $pipelineFactory->create($pipelineNumber));
        }
    }

    /**
     * @param AbstractParaunitProcess $process
     * @return Pipeline
     * @throws \RuntimeException
     */
    public function push(AbstractParaunitProcess $process): Pipeline
    {
        foreach ($this->pipelines as $pipeline) {
            if ($pipeline->isFree()) {
                $pipeline->execute($process);

                return $pipeline;
            }
        }

        throw new \RuntimeException('Cannot find an available pipeline');
    }

    public function hasEmptySlots(): bool
    {
        foreach ($this->pipelines as $pipeline) {
            if ($pipeline->isFree()) {
                return true;
            }
        }

        return false;
    }

    public function hasRunningProcesses(): bool
    {
        foreach ($this->pipelines as $pipeline) {
            if (! $pipeline->isTerminated()) {
                return true;
            }
        }

        return false;
    }

    public function triggerProcessTermination()
    {
        foreach ($this->pipelines as $pipeline) {
            $pipeline->triggerTermination();
        }
    }
}