0

编码：

$gmc = new GearmanClient();
$gmc->addServer();
$gmc->setCompleteCallback(function(GearmanTask $task){
    echo 'Complete: Task ' . $task->unique() . PHP_EOL;
});

for ($i=0; $i<10; $i++) {
    $gmc->addTask('queryShard', json_encode($taskData), null, 'Job:' . $i);
}

if (!$gmc->runTasks()) {
    echo "ERROR " . $gmc->error() . "\n";
}

我可以看到每个触发的任务何时完成。但是，有没有办法在所有启动的任务都成功时触发事件（请不要提供依赖手动任务注册表的解决方案）？

另外，任何人都可以建议如何将一组任务作为一个集合来管理吗？

谢谢！

4

2 回答 2

1

runTasks将阻止调用线程的执行，直到所有添加的前台任务完成。有关更多详细信息，请参阅 fiskfisk答案。然而，所有任务完成的事实并不意味着所有任务都成功完成。

Gearman 应用程序框架有意不对任务的（不）成功竞争做出假设。有许多 Gearman 客户端实现和无限数量的用例。开发人员有责任为相关用例提供最合适的解决方案。

最常见的是，我会使用SplObjectStorage类以及实现 created、fail、warning、exception 和 complete 回调来跟踪客户端的任务完成情况。当可能需要在工作人员端进行额外跟踪时，可能会有复杂的用例。

于 2013-10-12T11:38:00.027 回答
0

您可以使用以下内容：

$taskset = $gmc->new_task_set();
while(...) {
    $taskset->addTask(...);
}
$taskset->wait();

等到所有作业完成。

于 2013-10-10T13:36:08.710 回答