Code Duplication    Length = 5-5 lines in 2 locations

src/ParallelPool.php 2 locations

@@ 53-57 (lines=5) @@
50
    public function reload($block = true)
51
    {
52
        $old_processes = $this->processes;
53
        for ($i = 0; $i < $this->max; $i++) {
54
            $process = new Process($this->runnable);
55
            $process->start();
56
            $this->processes[$process->getPid()] = $process;
57
        }
58
59
        foreach ($old_processes as $process) {
60
            $process->shutdown();
@@ 99-103 (lines=5) @@
96
        // create sub process and run
97
        if ($alive_count < $this->max) {
98
            $need = $this->max - $alive_count;
99
            for ($i = 0; $i < $need; $i++) {
100
                $process = new Process($this->runnable);
101
                $process->start();
102
                $this->processes[$process->getPid()] = $process;
103
            }
104
        }
105
    }
106
}