Выход из петли Gearman

Я думаю, вы описали единственную проблему блокировки, а именно результаты поиска стороннего API. С моей точки зрения, у вас есть два способа справиться с этим: либо вы можете полностью прервать попытку, если решите, что у вас закончилось время, либо вы можете сообщить клиенту, что у вас закончилось время, но продолжить работу с в любом случае, просто для обновления вашего локального кеша на тот случай, если он будет отвечать медленнее, чем вам хотелось бы. Я опишу, как бы я решил первую проблему, потому что это было бы проще.

Со стороны клиента:

$request = array(
    'productId' => 5,
);
$client = new GearmanClient( );
$client->addServer( '127.0.0.1', 4730 );
$results = json_decode($client->doNormal('apiPriceLookup', json_encode( $request )));

if($results && property_exists($results->success) && $results->success) {
    // Use local data
} else {
    // Use fresh data
}

Это создаст задание на сервере заданий с именем функции 'apiPriceLookup' и передаст ему данные рабочей нагрузки, содержащие идентификатор продукта 5. Он дождется возврата результатов и проверит свойство success. Если он существует и истинен, то поиск API прошел успешно.

Идея состоит в том, чтобы установить условие тайм-аута в рабочей задаче, что полностью зависит от того, как вы реализуете поиск API. Если вы используете cURL (или какую-либо оболочку для cURL), вы можете увидеть ответ на вопрос, как определить тайм-аут здесь.

С рабочей стороны:

$worker= new GearmanWorker(); 
$worker->addServer(); 
$worker->addFunction("apiPriceLookup", "apiPriceLookup", $count);

while ($worker->work());

function apiPriceLookup($job) {
    $payload = json_decode($job->workload());

    try {
        $results = [
            'data' => PerformApiLookupForProductId($payload->productId),
            'success' => true,
        ];
    } catch(Exception $e) {
        $results = ['success' => false];
    }

    return json_encode($results);
}

Это просто создает объект GearmanWorker и подписывает его на функцию apiPriceLookup. Он будет вызывать функцию apiPriceLookup всякий раз, когда клиент отправляет задачу на сервер заданий. Эта функция вызывает другую функцию, PerformApiLookupForProductId, которая должна быть написана так, чтобы генерировать исключение всякий раз, когда возникает условие тайм-аута.

Я не думаю, что это будет рассматриваться как использование исключений для управления логическим потоком, я думаю, что условия тайм-аута обычно являются исключительными (или должны быть) событиями. Например, Guzzle выдаст GuzzleHttp\Exception\RequestException , когда решит тайм-аут.