(PECL gearman >= 0.5.0)
GearmanClient::addTaskLow — Добавить низкоприоритетную задачу для работы в параллельном режиме
$function_name,$workload,$context = null,$unique_key = nullДобавляет низкоприоритетную задачу для параллельной работы с другими задачами. Вызовите этот метод для всех задач, которые будут работать параллельно, а затем вызовите GearmanClient::runTasks() для выполнения работ. Задачи с низким приоритетом будут выбраны из очереди после задач с нормальным или высоким приоритетом.
function_nameЗарегистрированная функция, которую вызывает рабочий процесс
workloadСериализованные данные, которые подлежат обработке
contextКонтекст приложения, который связывается с задачей
unique_keyУникальный ID, который назначается конкретной задаче
Объект GearmanTask или false, если задача не может быть добавлена.
Пример #1 Низкоприоритетная задача вместе с двумя обычными задачами
Низкоприоритетная задача включена среди двух других задач. Единственный обработчик доступен, так что задачи запускаются одна за другой, низкоприоритетные задачи выполняются в последнюю очередь.
<?php
# создание клиента
$gmc= new GearmanClient();
# добавление сервера задач по умолчанию
$gmc->addServer();
# установка функции обратного вызова по завершению задачи
$gmc->setCompleteCallback("reverse_complete");
# добавление задач, одна из которых с низким приоритетом
$task= $gmc->addTask("reverse", "Hello World!", null, "1");
$task= $gmc->addTaskLow("reverse", "!dlroW olleH", null, "2");
$task= $gmc->addTask("reverse", "Hello World!", null, "3");
if (! $gmc->runTasks())
{
echo "Ошибка " . $gmc->error() . "\n";
exit;
}
echo "Готово\n";
function reverse_complete($task)
{
echo "Выполнено: " . $task->unique() . ", " . $task->data() . "\n";
}
?>Вывод приведённого примера будет похож на:
Выполнено: 3, !dlroW olleH Выполнено: 1, !dlroW olleH Выполнено: 2, Hello World! Готово