(PECL gearman >= 0.5.0)
GearmanClient::addTask — Ajoute une tâche à exécuter en parallèle
$function_name
, string $workload
[, mixed &$context
[, string $unique
]] )Ajoute une tâche à exécuter en parallèle d'autres tâches. Appelez cette méthode pour toutes les tâches à exécuter en parallèle, puis, appelez la méthode GearmanClient::runTasks() pour exécuter les tâches. Notez qu'il est nécessaire d'avoir assez d'agents disponibles pour exécuter en parallèle toutes les tâches.
function_name
Une fonction enregistrée que le travailleur va exécuter
workload
Données linéarisées à analyser
context
Contexte de l'application à associer avec une tâche
unique
Un identifiant unique utilisé pour identifier une tâche particulière
Un objet GearmanTask ou FALSE
si l tâche n'a pu être ajoutée.
Exemple #1 Ajout de 2 tâches
<?php
# Crée un client gearman
$gmclient= new GearmanClient();
# Ajoute le serveur de travaux par défaut
$gmclient->addServer();
# Ajoute une tâche exécutant la fonction "reverse" sur la chaîne "Hello World!"
$gmclient->addTask("reverse", "Hello World!", null, "1");
# Ajoute une autre tâche exécutant la fonction "reverse" sur la chaîne "!dlroW olleH"
$gmclient->addTask("reverse", "!dlroW olleH", null, "2");
# Définit une fonction à appeler lorsque le travail est terminé
$gmclient->setCompleteCallback("complete");
# Exécute les tâches
$gmclient->runTasks();
function complete($task)
{
print "Terminé : " . $task->unique() . ", " . $task->data() . "\n";
}
?>
L'exemple ci-dessus va afficher quelque chose de similaire à :
Terminé : 2, Hello World! Terminé : 1, !dlroW olleH
Exemple #2 Ajout de 2 tâches en passant le contexte de l'application
<?php
$client = new GearmanClient();
$client->addServer();
# Ajout de quelques tâches contenant un marqueur à l'emplacement duquel le résultat doit être placé
$results = array();
$client->addTask("reverse", "Hello World!", &$results, "t1");
$client->addTask("reverse", "!dlroW olleH", &$results, "t2");
$client->setCompleteCallback("reverse_complete");
$client->runTasks();
# Le résultat doit être maintenant contenu dans les fonctions de rappel
foreach ($results as $id => $result)
echo $id . ": " . $result['handle'] . ", " . $result['data'] . "\n";
function reverse_complete($task, $results)
{
$results[$task->unique()] = array("handle"=>$task->jobHandle(), "data"=>$task->data());
}
?>
L'exemple ci-dessus va afficher quelque chose de similaire à :
t2: H.foo:21, Hello World! t1: H:foo:22, !dlroW olleH