GearmanClient::addTask

    (PECL gearman >= 0.5.0)

    GearmanClient::addTask — Ajoute une tâche à exécuter en parallèle

    Description

    publicGearmanClient::addTask(
        string$function_name,
        string|int|float$workload,
        mixed$context = null,
        ?string$unique_key = null
    ): GearmanTask|false

    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.

    Liste de paramètres

    function_name

    Une fonction enregistrée que le travailleur va exécuter

    workload

    Données sérialisées à analyser

    context

    Contexte de l'application à associer avec une tâche

    unique_key

    Un identifiant unique utilisé pour identifier une tâche particulière

    Valeurs de retour

    Un objet GearmanTask ou false si l tâche n'a pu être ajoutée.

    Exemples

    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();

    # Défini une fonction à appeler lorsque le travail est terminé
    $gmclient->setCompleteCallback("complete");

    # 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");

    # Exécute les tâches
    $gmclient->runTasks();

    function     complete($task)
    {
    print     "Terminé : " . $task->unique() . ", " . $task->data() . "\n";
    }

    ?>

    Résultat de l'exemple ci-dessus est 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();

    # Défini une fonction à appeler lorsque le travail est terminé
    $client->setCompleteCallback("reverse_complete");

    # 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->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());
    }

    ?>

    Résultat de l'exemple ci-dessus est similaire à :

    t2: H.foo:21, Hello World! t1: H:foo:22, !dlroW olleH

    Voir aussi

    To Top