Задание таймаута ожидания ввода/вывода на сокете


(PECL gearman >= 0.6.0)

GearmanWorker::setTimeout Задание таймаута ожидания ввода/вывода на сокете

Описание

public bool GearmanWorker::setTimeout ( int $timeout )

Устанавливает таймаут ожидания активности на сокете.

Список параметров

timeout

Временной интервал в миллисекундах. Отрицательное значение указывает на отсутствие ограничений.

Возвращаемые значения

Всегда возвращает TRUE.

Примеры

Пример #1 Простой обработчик с пятисекундным таймаутом

<?php

echo "Запуск\n";

# создаем объект обработчика.
$gmworker= new GearmanWorker();

# добавляем сервер по умолчанию (localhost).
$gmworker->addServer();

# регистрируем функцию "reverse" на сервере
$gmworker->addFunction("reverse""reverse_fn");

# устанавливаем таймаут ожидания 5 секунд
$gmworker->setTimeout(5000);

echo 
"Ожидание задания...\n";
while(@
$gmworker->work() || $gmworker->returnCode() == GEARMAN_TIMEOUT)
{
  if (
$gmworker->returnCode() == GEARMAN_TIMEOUT)
  {
    
# Normally one would want to do something useful here ...
    
echo "Время вышло. Ожидание следующего задания...\n";
    continue;
  }

  if (
$gmworker->returnCode() != GEARMAN_SUCCESS)
  {
    echo 
"код возврата: " $gmworker->returnCode() . "\n";
    break;
  }
}

echo 
"Готово\n";

function 
reverse_fn($job)
{
  return 
strrev($job->workload());
}

?>

Если запустить этот обработчик и не передавать ему заданий, вывод будет примерно таким:

 Запуск Ожидание задания... Время вышло. Ожидание следующего задания... Время вышло. Ожидание следующего задания... Время вышло. Ожидание следующего задания... 

Смотрите также

  • GearmanWorker::timeout() - Получение значения таймаута ожидания запросов на сокете