Блог

У меня есть сервер Gearman, на котором выполняется процесс, завершение которого занимает несколько минут. Я запускаю индикатор выполнения, чтобы показать завершение, и пытаюсь получить проценты для столбца, используя расширение Gearman PHP и функцию JobStatus().

Задание определенно активно и найдено, поскольку первые два поля (известно все еще выполняется) возвращаются к true. Однако третье и четвертое поля (числитель и знаменатель процента завершения) возвращаются ни с чем. Кто-нибудь знает, почему это может быть или как вычисляются эти числа?

 public bool GearmanJob::sendStatus ( int $numerator , int $denominator )
  

Отправляет информацию о состоянии задания
сервер и все прослушивающие клиенты. Использование
это для того, чтобы указать, какой процент от
задание завершено.

Чтобы иметь возможность использовать его, вам, вероятно, также придется немного изменить клиент для обработки обмена данными.

Пример

client.php

 <?php
global $argc,$argv;

if (!file_exists($argv[1])) {
        echo "File not foundn";
        exit(1);
}

$gmclient= new GearmanClient();
$gmclient->addServer();
do
{
  $result = $gmclient->do("linecount", file_get_contents($argv[1]));
  # Check for various return packets and errors.

  switch($gmclient->returnCode())
  {
    case GEARMAN_WORK_STATUS:
      list($numerator, $denominator)= $gmclient->doStatus();
      echo "Status: " . sprintf("%d%%",($numerator/$denominator)*100)
             . " completer";
      break;
    case GEARMAN_SUCCESS:
      break;
  }
}
while($gmclient->returnCode() != GEARMAN_SUCCESS);

echo "nResult: $resultn";
  

worker.php

 <?php
$worker= new GearmanWorker();
$worker->addServer();
$worker->addFunction("linecount", "linecount");
while ($worker->work());

    function linecount($job)
    {
            $lines = preg_split('/[rn]/',
                       $job->workload(),null,PREG_SPLIT_NO_EMPTY);
            $linecount = count($lines);
            $n = 0;
            foreach ($lines as $line) {
                    usleep(3000);
                    $n  ;
                    $job->sendStatus($n,$linecount);
                    $ret  ;
            }
            return $ret;
    }
  

Настроен ли рабочий на возврат статуса?

Однако, если вы пишете их самостоятельно, вам придется проделать немного дополнительной работы, чтобы заставить их возвращать детали по мере их выполнения.