L'appel d'une fonction dans un thread d'arrière-plan / processus (fork)

J'ai un code qui est un peu comme ceci:

($i=0; $i < 100; $i++)
{
   do ($foo[$i]);
}

Ci-dessus est une période intensive de la tâche, et j'espérais être en mesure de créer une fonction, et de l'appeler deux fois, comme ci-dessous

function wrapper($start;$end)
{
    ($i=$start; $i < $end; $i++)
    {
       do ($foo[$i]);
    }
}
//have both of these run in parallel
wrapper(0,50);
wrapper(51,100);

J'ai regardé Gearman, mais je ne peux pas l'utiliser comme je ne peux pas installer le gearman serveur (depuis que je suis sur un serveur partagé). Il semble que la façon d'y parvenir serait par bifurquer. J'ai essayé de lire beaucoup sur le sujet, mais de documentation et de soutien sont peu nombreuses. Toute aide /filaire code serait appréciée.

Pour définir ma question, comment pourrais-je appeler wrapper() en passant des arguments tels qu'il s'exécute dans un processus enfant. Aussi, il est important que je sois en mesure d'enregistrer une fonction de rappel.

Détails supplémentaires: PHP 5.3, en cours d'exécution sur un serveur Linux. Script est exécuté par le cgi-fcgi.

Je pense que c'est comment je suis censé lancer un processus enfant, mais comment puis-je l'utiliser pour frayer les multiples processus enfants? Et comment puis-je enregistrer une fonction de rappel?

$pid = pcntl_fork(); 

if ( $pid == -1 ) {        
    //Fork failed            
    exit(1); 
} else if ( $pid ) { 
    //The parent process
    //should I repeat this same code here to spawn another child process?

} else { 
    //the child process 
    //can I call wrapper from here and will it run in this child process?
InformationsquelleAutor xbonez | 2012-01-26
  1. 12

    De "Tudor Barbu du blog professionnel"

    (http://blog.motane.lu/2009/01/02/multithreading-in-php/)

    require_once( 'Thread.php' );

//test to see if threading is available
if( ! Thread::isAvailable() ) {
    die( 'Threads not supported' );
}

//function to be ran on separate threads
function paralel( $_limit, $_name ) {
    for ( $index = 0; $index < $_limit; $index++ ) {
        echo 'Now running thread ' . $_name . PHP_EOL;
        sleep( 1 );
    }
}

//create 2 thread objects
$t1 = new Thread( 'paralel' );
$t2 = new Thread( 'paralel' );

//start them
$t1->start( 10, 't1' );
$t2->start( 10, 't2' );

//keep the program running until the threads finish
while( $t1->isAlive() && $t2->isAlive() ) {

}

    Télécharger Thread.php

    • Merci. Cela semble être un brillant wrapper. Je suis à la recherche dans le code de droit maintenant
    • Le lien de la référence, il est également mauvais pour utiliser un vide boucle pour vérifier si les fils sont en vie, car il va utiliser tout votre CPU. Vous devez inclure un sommeil dans la boucle.
    • une meilleure solution est de mettre en œuvre un join capacité de la bibliothèque, devrait être assez simple à faire.
    • La méthode 'disponible' ne trouve pas dans la classe Thread
    • Comment puis-je commencer une méthode de classe à l'aide de cette approche?
    InformationsquelleAutor Beel
  2. 3

    Si vous utilisez Linux, vous pouvez profiter de la ligne de commande et ne

    public function newWrapperInstance($start,$end){
    exec('bash -c "exec nohup setsid php-cli yourFile.php '.$start.' '.$end.' > /dev/null 2>&1 &"');
}

    Cela va créer une nouvelle instance de PHP dans le fond et de se détacher de la fonction exec dans le thread principal.

    Avertissement:
    Le seul inconvénient est que vous ne pouvez pas contrôler ce que ces fils ne sont une fois qu'ils sont créés.

    InformationsquelleAutor 0xen