Gearman setCompleteCallback ne fonctionne pas

Question

Il semble que setCompleteCallback ne fonctionne pas chez moi. Qu'est-ce que je fais mal? Merci.

<?php 
    # Create our client object. 
    $client = new GearmanClient(); 

    # Add default server (localhost). 
    $client->addServer("127.0.0.1", 4730); 

    echo "Sending job\n"; 

    $client->addTask("reverse", "Hello!", null, "1"); 
    $client->addTask("reverse", "Hello!", null, "2"); 
    $client->setCompleteCallback("complete"); 
    $client->runTasks(); 

    function complete($task) 
    { 
     print "Выполнено: " . $task->unique() . ", " . $task->data() . "\n"; 
    } 

    ?> 

EDIT:

<?php 
$worker = new GearmanWorker(); 
$worker->addServer("127.0.0.1", 4730); 
$worker->addFunction("reverse", "reverse_fn"); 
while (1) { 
    $ret = $worker->work(); 
    if ($worker->returnCode() != GEARMAN_SUCCESS) 
     break; 
} 
function reverse_fn($job) 
{ 
    $workload = $job->workload(); 
    sleep(5); 
    $result = strrev($workload); 
    $job->sendComplete($result); 
    return $result; 
} 
?> 

Ceci est mon travailleur. Toujours pas fonctionne. Peut-être que j'ai besoin d'autre chose?

Answer 1

Vous devez définir un rappel complet avant d'ajouter des tâches.

$client->setCompleteCallback("complete"); 
$client->addTask("reverse", "Hello!", null, "1"); 
$client->addTask("reverse", "Hello!", null, "2"); 

Answer 2

Vous devez envoyer un état complet dans votre script de travail. GearmanJob::sendComplete.