(PECL gearman >= 0.6.0)
GearmanWorker::wait — Attente une activité d'un ou plusieurs serveurs de travaux
Met à attente l'agent d'une activité d'un ou plusieurs serveurs de travaux lors
d'un fonctionnement en mode I/O non bloquant. En cas d'échec, une alerte de niveau
E_WARNING sera émise avec le contenu de la dernière erreur Gearman
survenue.
Cette fonction ne contient aucun paramètre.
Cette fonction retourne TRUE en cas de
succès ou FALSE si une erreur survient.
Exemple #1 Exécution d'un agent en mode non bloquant
<?php
echo "Début\n";
# Crée un nouvel agent
$worker= new GearmanWorker();
# Rend l'agent non bloquant
$worker->addOptions(GEARMAN_WORKER_NON_BLOCKING);
# Ajoute un serveur par défaut (localhost, port 4730)
$worker->addServer();
# Ajoute une fonction "reverse"
$worker->addFunction('reverse', 'reverse_fn');
# Tente de récupérer un travail
while (@$worker->work() ||
$worker->returnCode() == GEARMAN_IO_WAIT ||
$worker->returnCode() == GEARMAN_NO_JOBS)
{
if ($worker->returnCode() == GEARMAN_SUCCESS)
continue;
echo "Attente du premier travail...\n";
if (!@$worker->wait())
{
if ($worker->returnCode() == GEARMAN_NO_ACTIVE_FDS)
{
# Nous ne sommes connectés à aucun serveur ; nous attendons donc un peu
# avant de tenter une reconnexion.
sleep(5);
continue;
}
break;
}
}
echo "Erreur de l'agent : " . $worker->error() . "\n";
function reverse_fn($job)
{
return strrev($job->workload());
}
?>