slince / process

SignalHandler.php

<?php
/**
 * Process Library
 * @author Tao <taosikai@yeah.net>
 */
namespace Slince\Process;

use Slince\Process\Exception\InvalidArgumentException;

class SignalHandler
{
    /**
     * The handlers
     * @var array
     */
    protected $handlers = [];

    /**
     * Registers a callback for some signals
     * @param int|array $signals a signal or an array of signals
     * @param callable|int $callback a callback
     * @return SignalHandler;

The doc-type SignalHandler; could not be parsed: Expected "|" or "end of type", but got ";" at position 13. (view supported doc-types)

     */
    public function register($signals, $callback)
    {
        if (!is_array($signals)) {
            $signals = [$signals];
        }
        foreach ($signals as $signal) {
            $this->setSignalHandler($signal, $callback);
        }
        return $this;
    }

    /**
     * Register a callback for
     * @param $signal
     * @param int|callable $handler
     */
    protected function setSignalHandler($signal, $handler)
    {
        if (!is_int($handler) && !is_callable($handler)) {
            throw new InvalidArgumentException('The signal handler should be called or a number');
        }
        $this->handlers[$signal] = $handler;
        pcntl_signal($signal, $handler);
    }

    /**
     * Gets the handler for a signal
     * @param $signal
     * @return int|string
     */
    public function getHandler($signal)
    {
        if (function_exists('pcntl_signal_get_handler')) {
            return pcntl_signal_get_handler($signal);
        }
        return isset($this->handlers[$signal]) ? $this->handlers[$signal] : null;
    }


    /**
     * Creates a handler
     * @param boolean $disableDeclareTicks disable declare(tickets = 1)
     * @return SignalHandler
     */
    public static function create($disableDeclareTicks = false)

The parameter $disableDeclareTicks is not used and could be removed.

    {
        $handler = new static();
        if (function_exists('pcntl_async_signals')) {
            pcntl_async_signals(true);
        } else {
            declare (ticks = 1);
        }
        return $handler;
    }
}