L'exécution des fonctions en parallèle en PHP

Peut appeler une fonction PHP et ne pas attendre qu'il revienne? Donc quelque chose comme ceci:

function callback($pause, $arg) {
    sleep($pause);
    echo $arg, "\n";
}

header('Content-Type: text/plain');
fast_call_user_func_array('callback', array(3, 'three'));
fast_call_user_func_array('callback', array(2, 'two'));
fast_call_user_func_array('callback', array(1, 'one'));

serait sortie de

one (after 1 second)
two (after 2 seconds)
three (after 3 seconds)

plutôt que

three (after 3 seconds)
two (after 3 + 2 = 5 seconds)
one (after 3 + 2 + 1 = 6 seconds)

Script principal est prévu pour être exécuté en tant que processus permanent (serveur TCP). callback() la fonction est de recevoir des données de client, effectuer des script PHP et de faire quelque chose sur la base d'autres arguments qui sont passés à callback(). Le problème est que le script principal ne doit pas attendre externe script PHP à la fin. Résultat de script externe est importante, donc exec('php -f file.php &') n'est pas une option.

Edit:
Beaucoup ont recommandé de prendre un coup d'oeil à PCNTL, de sorte qu'il semble qu'une telle fonctionnalité puisse être atteint. PCNTL n'est pas disponible dans Windows, et je n'ai pas accès à une machine Linux, donc je ne peux pas le tester, mais si beaucoup de gens l'ont conseillé, alors il devrait faire l'affaire 🙂

Merci à chacun de vous!

OriginalL'auteur binaryLV | 2010-06-08

  1. 12

    Sur plates-formes Unix, vous pouvez activer le PCNTL fonctions, et l'utilisation pcntl_fork à la fourchette le processus et d'exécuter vos tâches dans les processus enfants.

    Quelque chose comme:

    function fast_call_user_func_array($func, $args) {
  if (pcntl_fork() == 0) {
    call_user_func_array($func, $args);
  }
}

    Une fois que vous appelez pcntl_fork, deux processus de l'exécution de votre code à partir de la même position. Le processus parent obtiendrez un PID retourné à partir de pcntl_fork, tandis que le processus enfant d'obtenir 0. (Si il y a une erreur, le processus parent sera de retour -1, qui est la peine de vérifier dans le code de production).

    Encore une fois, fork() et le fils sont deux choses complètement différentes. PHP n'a pas de notion de threads. Fork() prend un seul exécutant php processus et des "copies" sur un deuxième processus (copie de toutes les variables, etc). Il n'y a aucun moyen de retourner la valeur d'un processus à un autre sans une certaine forme de l'IPC. C'est TRÈS différent de filetage...
    la droite. Je suppose que j'ai été un peu lâche avec ma terminologie. s/thread/processus/g 🙂

    OriginalL'auteur Chris

  2. 2

    Vous pouvez vérifier PHP le Contrôle des Processus:

    http://us.php.net/manual/en/intro.pcntl.php

    Note: Ceci est pas de filetage, mais la manipulation de processus distincts. Il n'y a plus de frais généraux attachés.

    Je ne sais pas ce que je dirais qu'il y a plus de frais généraux attachés en général. Sur Windows, bien sûr, fork()ing est cher. Mais sur Linux, c'est vraiment très bon marché. Les "frais généraux" dont vous parlez pourrait être considéré comme ayant besoin de traiter avec l'IPC (vous ne pouvez pas simplement return une valeur à partir d'un processus à un autre, si vous avez besoin d'un peu de code pour gérer la communication)... Si votre processus sont très indépendants, la fourche peut être le moyen le plus efficace pour gérer leur...
    Les processus ont leur propre état et de la mémoire de l'espace. Fils ne sont pas. C'est la surcharge dont je parle.
    Tout à fait vrai, mais sur Linux, fork() utilise la copie sur écriture de la mémoire de partage. Donc, la pile serait copié, mais le reste du processus, ne serait copié lorsque la mémoire est effectivement changé. C'est vraiment très efficace (il peut être plus efficace que le filetage si vous n'avez pas besoin de la CIB, car il résout l'affinité du processeur problème de filetage si vous avez plus de 1 CPU)...
    La droite. Il dépendra de la façon dont les OP utilise le processus si une telle surcharge de l'appeler ou pas.

    OriginalL'auteur webbiedave

  3. 2

    Ne serait-il pas de résoudre votre problème à la fourchette, en gardant le processus parent libres pour d'autres connexions & actions? Voir http://www.php.net/pcntl_fork. Si vous avez besoin d'une réponse de retour que vous pourriez éventuellement écouter un socket dans le parent, et à écrire avec l'enfant. Un simple while(true) boucle avec une lecture pourrait éventuellement faire, et probablement que vous avez déjà des fonctionnalités de base si vous exécutez un permanent serveur TCP. Une autre option serait de garder une trace de votre childprocess-id, garder un accessible stocker quelque part (fichier/base de données/memcached, etc), avec un pcnt_wait dans le processus principal avec un WNOHANG pour vérifier le processus a quitté, et de récupérer des données à partir de la boutique.

    OriginalL'auteur Wrikken

  4. 1

    Vous pouvez faire un peu de filetage en PHP si vous utilisez la méthode pcntl_fork.

    http://ca.php.net/manual/en/function.pcntl-fork.php

    Je n'ai jamais utiliser ce moi-même, mais le sont certains bon exemple de la façon de l'utiliser sur php.net.

    Ce n'est pas du filetage. Fork()ing crée un nouveau processus comme une copie de l'actuel. Vous ne pouvez pas les valeurs de retour ou de partager des variables à partir d'un processus à un autre (vous avez besoin d'utiliser une certaine forme de l'IPC: les sockets mémoire partagée, fifo fichiers, etc).

    OriginalL'auteur HoLyVieR

  5. 0

    PHP ne dispose pas de cette fonctionnalité pour autant que je sais

    Vous pouvez émuler la fonction à l'aide d'une technique différente, comme celle-ci:
    En parallèle des fonctions en PHP

    Je pensais aussi que PHP ne dispose pas d'une telle fonctionnalité, mais je n'étais pas sûr, donc je demande ici, et il s'avère que PCNTL pourrait faire l'affaire.
    nous apprenons quelque chose de nouveau tous les jours

    OriginalL'auteur zaczap

  6. 0

    PHP ne gère pas le multi-threading, donc il n'y a pas d'autre option que de profiter de l'OS ou le serveur web multi capacités de traitement. Notez que vous pouvez récupérer à la fois le résultat et la sortie de exec:

    chaîne exec ( string $commande [[,
    array &$sortie [, int &$return_var
    ]] )

    OriginalL'auteur nuqqsa

  7. 0

    Vous pouvez, au moins, de prévenir le processus parent de la pendaison jusqu'à ce que le processus de l'enfant se fait en ignorant l'enfant signaux à l'aide de pcntl_signal(SIGCHLD, SIG_IGN).

    Donc, disons que vous voulez à la fourche d'un processus et d'en exécuter une autre fonction PHP qui prend un certain temps sans faire le parent attendre qu'elle se termine (comme vous voulez le processus principal de finir en temps opportun):

    pcntl_signal(SIGCHLD, SIG_IGN);
$pid = pcntl_fork();
if ($pid < 0) {
  exit(0);
} elseif (!$pid) {
  my_slow_function();
  exit(0);
}
//Parent keeps executing and finishes before the child does

    Si vous souhaitez exécuter une lente script externe comme le processus de l'enfant, pcntl_exec est à portée de main:

    $script = array('/path/to/my/script'); //E.g. /home/my_user/my_script.php
pcntl_exec('/path/to/program/executable',$script); //E.g. /usr/bin/php

    OriginalL'auteur aruanoc