GearmanController.php

<?php

namespace filsh\yii2\gearman;

use Yii;
use yii\console\Controller;
use yii\helpers\Console;
use Sinergi\Gearman\Process;
use Sinergi\Gearman\Application;

class GearmanController extends Controller
{
    /**
     * @var boolean whether to run the forked process.
     */
    public $fork = false;
    
    public $gearmanComponent = 'gearman';
    
    public function actionStart()
    {
        $app = $this->getApplication();
        $process = $app->getProcess();
        
        if ($process->isRunning()) {
            $this->stdout("Failed: Process is already running\n", Console::FG_RED);
            return;
        }
        
        $this->runApplication($app);
    }
    
    public function actionStop()
    {
        $app = $this->getApplication();
        $process = $app->getProcess();
        
        if ($process->isRunning()) {
            $this->stdout("Success: Process is stopped\n", Console::FG_GREEN);
        } else {
            $this->stdout("Failed: Process is not stopped\n", Console::FG_RED);
        }
        
        $process->stop();
    }
    
    public function actionRestart()
    {
        $app = $this->getApplication();
        $process = $app->getProcess();
        
        if (!$process->isRunning()) {
            $this->stdout("Failed: Process is not running\n", Console::FG_RED);
            return;
        }
        
        unlink($process->getPidFile());
        $process->release();

        $int = 0;
        while ($int < 1000) {
            if (file_exists($process->getPidFile())) {
                usleep(1000);
                $int++;
            } elseif (file_exists($process->getLockFile())) {
                $process->release();
                usleep(1000);
                $int++;
            } else {
                $int = 1000;
            }
        }
        
        $app->setProcess(new Process($app->getConfig(), $app->getLogger()));
        $this->runApplication($app);
    }
    
    public function options($id)
    {
        $options = [];
        if(in_array($id, ['start', 'restart'])) {
            $options = ['fork'];
        }
        
        return array_merge(parent::options($id), $options);
    }
    
    protected function getApplication()
    {
        $component = Yii::$app->get($this->gearmanComponent);
        return $component->getApplication();
    }
    
    protected function runApplication(Application $app)
    {
        $fork = (bool) $this->fork;
        if($fork) {
            $this->stdout("Success: Process is started\n", Console::FG_GREEN);
        } else {
            $this->stdout("Success: Process is started, but not daemonized\n", Console::FG_YELLOW);
        }
        
        $app->run((bool) $this->fork);
    }
}