GearmanClient::addTask

    (PECL gearman >= 0.5.0)

    GearmanClient::addTask — Añade una tarea para ser ejecutada en paralelo

    Descripción

    publicGearmanClient::addTask(
        string$function_name,
        string$workload,
        mixed&$context = ?,
        string$unique = ?
    ): GearmanTask

    Añade una tarea para ser ejecutada en paralelo con otras tareas. Debe llamarse a este método en todas las tareas que van a ejecutarse en paralelo y, entonces, llamar a GearmanClient::runTasks() para realizar el trabajo. Notar que se necesitan al menos tantos trabajadores como tareas para que puedan ejecutarse todos en paralelo de forma simultánea.

    Parámetros

    function_name

    Función registrada que ejecutará el worker

    workload

    Datos serializados a ser procesados

    context

    Aplicación context a asociar con la tarea

    unique

    ID único para identificar una tarea en particular

    Valores devueltos

    Un objeto GearmanTask o false si no se puede añadir la tarea.

    Ejemplos

    Ejemplo #1 Envío básico de dos tareas

    <?php

    # Crear el servidor Gearman
    $gmclient= new GearmanClient();

    # Establece una función a ser llamada cuando se complete el trabajo
    $gmclient->setCompleteCallback("complete");

    # Añade el servidor por defecto
    $gmclient->addServer();

    # Añade una tarea que ejecuta la función "reverse" al string "Hello World!"
    $gmclient->addTask("reverse", "Hello World!", null, "1");

    # Añade otra tarea para ejecutar la función "reverse" en el string "!dlroW olleH"
    $gmclient->addTask("reverse", "!dlroW olleH", null, "2");

    # Ejecuta las tareas
    $gmclient->runTasks();

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

    ?>

    El resultado del ejemplo sería algo similar a:

    COMPLETE: 2, Hello World! COMPLETE: 1, !dlroW olleH

    Ejemplo #2 Envío básico de dos tareas pasando contexto de la aplicación

    <?php

    $client     = new GearmanClient();
    $client->addServer();

    # Establece una función a ser llamada cuando se complete el trabajo
    $client->setCompleteCallback("reverse_complete");


    # Añade algunas tareas y provee de un lugar donde poner los resultados
    $results = array();
    $client->addTask("reverse", "Hello World!", &$results, "t1");
    $client->addTask("reverse", "!dlroW olleH", &$results, "t2");

    $client->runTasks();

    # Los resultados deberían estar rellenos
    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());
    }

    ?>

    El resultado del ejemplo sería algo similar a:

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

    Ver también

    To Top