View GitHub Repository simple-fork-php

Schedule Inspection
Subscribe

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
                                    
                                    
}