Login   Register  
PHP Classes
elePHPant
Icontem

File: example.php

Recommend this page to a friend!
Stumble It! Stumble It! Bookmark in del.icio.us Bookmark in del.icio.us
  Classes of Don Bauer  >  Power Spawn  >  example.php  >  Download  
File: example.php
Role: Example script
Content type: text/plain
Description: PowerSpawn Usage Example
Class: Power Spawn
Manage forked processes with the pcntl extension
Author: By
Last change:
Date: 3 years ago
Size: 2,997 bytes
 

Contents

Class file image Download
<?php
// Include PowerSpawn
require_once('PowerSpawn.class.php');

// Initialize the object
$ps = new PowerSpawn;

// Create a callback function (Not required)
function allChildrenComplete() {
    echo 
"All the children processes have completed\n";
}

function 
killedChild() {
    echo 
"A child was just killed\n";
}

// Setup PowerSpawn Config
$ps->setCallback('allChildrenComplete');    // Calls the allChildrenComplete() function when all processes have checked in and there is no more work to complete
$ps->setKillCallback('killedChild');        // Calls the killedChild function when a child is executed for exceeding time limit
$ps->maxChildren 5;                // Only allows 5 children to be running at any given time
$ps->timeLimit 10;                // Kills children processes that run longer than 10 seconds

// Build an array with some fake data to proccess
$data = array();
for (
$i 0$i 15$i++) {
    
$data[] = $i;
}

// Start the parent loop
while ($ps->runParentCode()) {
    
// Only the parent process will run code inside this loop
    
    // Determine if we still have data to process
    
if (count($data)) {
        
// We still have data to process
        // Check to see if we have an open slot to spawn a child
        
if ($ps->spawnReady()) {
            
// We can spawn a new process
            
$ps->childData array_shift($data);
            
            
// Echo some text to let the user know that this is the parent and we are spawning a new child
            
echo "[PARENT] Spawning a new process\n";
            
            
// Spawn the process
            
$ps->spawnChild();
        } else {
            
// All slots are full, just tick for now
            
$ps->Tick();
        }
    } else {
        
// There is no more data to process
        
        // Echo some text to let the user know that the parent process is out of data
        
echo "[PARENT] Out of data to hand out - Waiting for all children to check in\n";
        
        
// Call the shutdown() method - blocks until all chilren have checked in or been killed because of executing too long
        
$ps->shutdown();
        
        
// All child processes have terminated
        
echo "[PARENT] All child processes have completed\n";
    }
}

// Start the children code section
if ($ps->runChildCode()) {
    
// Only child processes forked by the parent will run this code
    // The parent process will not execute this code
    
    // Get the data for this run
    
$myNumber $ps->childData;
    
    
// Let the user know the thread is running
    
echo "[CHILD:{$myNumber}] Running with number {$myNumber} - My PID is {$ps->myPID()}\n";
    
    
// Now we'll sleep x seconds where x is $myNumber - but we'll loop to show that we are doing work
    
$x 0;
    while (
$x $myNumber) {
        
sleep(1);
        
$x++;
        echo 
"[CHILD:{$myNumber}] Just completed iteration {$x} of {$myNumber}\n";
    }

    
// Let the user know that all work has been completed
    // All children that run longer than 10 seconds won't make it this far with the settings above
    
echo "[CHILD:{$myNumber}] I have completed my work\n";
}


// Send signal 0 to let parent process know we are done
exit(0);

?>