Gearman basic worker structure

gistfile1.php

<?php
class Worker
{
  public function __construct($host, $port)
  {
    $this->worker = new GearmanWorker();
    $this->worker->addServer($host, $port);
    echo 'Waiting for work...' . PHP_EOL;
  }

  public function set_id_prefix($worker_id_prefix)
  {
    $this->worker->setId($worker_id_prefix . uniqid(true));
  }

  public function register_function($function)
  {
    $this->worker->addFunction($function, array($this, $function . '_action'));
  }

  public function run()
  {
    while($this->worker->work())
    {
      if ($this->worker->returnCode() != GEARMAN_SUCCESS)
      {
        echo $this->worker->returnCode() . PHP_EOL;
        break;
      }
    }
  }
}