EngKhaledB · December 17, 2021 04:18
diff --git a/SIMPLE_PARALLEL_PROCESSING_IN_PHP_WITH_PCNTL_FORK.php b/SIMPLE_PARALLEL_PROCESSING_IN_PHP_WITH_PCNTL_FORK.php
 <?php
 # Source: https://jrsinclair.com/articles/2013/simple-parallel-processing-in-php-with-pcntl-fork/

 // A function to run
 $makeDir = function($a) {
    shell_exec('mkdir '.shellescapearg($a));
 }
 
 // An array to process
 $dirnames = array('a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k');
 
 // Run the process in parallel.
 processParallel($makeDir, $dirnames, 8);

 /**
 * Process in Parallel.
 *
 * Run a function (with no return result) on each item in an array in parallel.
 * Note: This function is only useful if order is not important, and you don't
 * need any return values from the function (i.e. no inter-process communication).
 *
 * @param mixed   $func  A closure function to apply to each item in parallel.
 * @param array   $arr   The array to apply function to.
 * @param integer $procs Number of processes to run in parallel.
 *
 * @return void
 */
 function processParallel($func, array $arr, $procs=4)
 {
    // Break array up into $procs chunks.
    $chunks   = array_chunk($arr, ceil((count($arr) / $procs)));
    $pid      = -1;
    $children = array();
    foreach ($chunks as $items) {
        $pid = pcntl_fork();
        if ($pid === -1) {
             die('could not fork');
        } else if ($pid === 0) {
            // We are the child process. Pass a chunk of items to process.
            array_walk($items, $func);
            exit(0);
        } else {
            // We are the parent.
            $children[] = $pid;
        }
    }
 
    // Wait for children to finish.
    foreach ($children as $pid) {
        // We are still the parent.
        pcntl_waitpid($pid, $status);
    }
 }
	<?php
	# Source: https://jrsinclair.com/articles/2013/simple-parallel-processing-in-php-with-pcntl-fork/

	// A function to run
	$makeDir = function($a) {
	shell_exec('mkdir '.shellescapearg($a));
	}

	// An array to process
	$dirnames = array('a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k');

	// Run the process in parallel.
	processParallel($makeDir, $dirnames, 8);

	/**
	* Process in Parallel.
	*
	* Run a function (with no return result) on each item in an array in parallel.
	* Note: This function is only useful if order is not important, and you don't
	* need any return values from the function (i.e. no inter-process communication).
	*
	* @param mixed $func A closure function to apply to each item in parallel.
	* @param array $arr The array to apply function to.
	* @param integer $procs Number of processes to run in parallel.
	*
	* @return void
	*/
	function processParallel($func, array $arr, $procs=4)
	{
	// Break array up into $procs chunks.
	$chunks = array_chunk($arr, ceil((count($arr) / $procs)));
	$pid = -1;
	$children = array();
	foreach ($chunks as $items) {
	$pid = pcntl_fork();
	if ($pid === -1) {
	die('could not fork');
	} else if ($pid === 0) {
	// We are the child process. Pass a chunk of items to process.
	array_walk($items, $func);
	exit(0);
	} else {
	// We are the parent.
	$children[] = $pid;
	}
	}

	// Wait for children to finish.
	foreach ($children as $pid) {
	// We are still the parent.
	pcntl_waitpid($pid, $status);
	}
	}