ByJG\PHPThread\Handler\PThreadHandler

Complexity

Total Complexity

20

Size/Duplication

Total Lines	139
Duplicated Lines	2.16 %

Coupling/Cohesion

Components	2
Dependencies	0

Importance

Changes	10
Bugs	2	Features	2

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getLoader()	0	17	4
A	run()	0	19	4
A	execute()	0	5	1
A	getResult()	3	9	4
A	stop()	0	4	1
A	isAlive()	0	12	3
A	setCallable()	0	4	1
A	waitFinish()	0	4	1

<?php

namespace ByJG\PHPThread\Handler;

use Composer\Autoload\ClassLoader;

class PThreadHandler extends \Thread implements ThreadInterface
{
    /**
     * @var ClassLoader
     */
    private $loader;

    /**
     * @var callable
     */
    private $callable;

    private $args;

    private $result;

    /**
     * Thread constructor.
     */
    public function __construct()
    {
        $this->getLoader();
    }

    /**
     * @return ClassLoader
     */
    public function getLoader()
    {
        if (!is_null($this->loader)) {
            return $this->loader;
        }

        $path = __DIR__ . '/../../vendor/autoload.php';
        if (!file_exists($path)) {
            $path = __DIR__ . '/../../../../autoload.php';
            if (!file_exists($path)) {
                throw new \RuntimeException("Autoload path '$path' not found");
            }
        }
        $this->loader = require("$path");

        return $this->loader;
    }

    /**
     * Here you are in a threaded environment
     */
    public function run()
    {
        $this->getLoader()->register();

        $callable = $this->callable;
        if (!is_string($callable)) {
            $callable = (array) $this->callable;
        }

        try {
            $this->result = call_user_func_array($callable, (array)$this->args);
        // Executed only in PHP 7, will not match in PHP 5.x
        } catch (\Throwable $ex) {

The class Throwable does not exist. Did you forget a USE statement, or did you not list all dependencies?

            $this->result = $ex;
        // Executed only in PHP 5. Remove when PHP 5.x is no longer necessary.
        } catch (\Exception $ex) {
            $this->result = $ex;
        }
    }

    /**
     * Start the thread
     *
     * @throws \RuntimeException
     */
    public function execute()
    {
        $this->args = func_get_args();
        return parent::start();

It seems like you call parent on a different method (start() instead of execute()). Are you sure this is correct? If so, you might want to change this to $this->start().

    }

    /**
     * Get the thread result
     *
     * @return mixed
     * @throws \Exception
     */
    public function getResult()
    {
        $result = $this->result;
        if (is_object($result) && (is_subclass_of($result, '\\Error') || is_subclass_of($result, '\\Exception'))) {

This code seems to be duplicated across your project.

            throw $result;
        }

        return $result;
    }

    /**
     * Kill a thread
     *
     * @param int $signal
     * @param bool $wait
     */
    public function stop($signal = SIGKILL, $wait = false)
    {
        parent::kill();

It seems like you call parent on a different method (kill() instead of stop()). Are you sure this is correct? If so, you might want to change this to $this->kill().

    }

    /**
     * Checkif the thread is not Terminated
     *
     * @return bool
     */
    public function isAlive()
    {
        if ($this->isRunning()) {
            return true;
        }

        if (!$this->isJoined()) {
            $this->join();
        }

        return false;
    }

    /**
     * Set the thread callable method
     * @param callable $callable
     * @return mixed
     */
    public function setCallable(callable $callable)
    {
        $this->callable = $callable;
    }

    public function waitFinish()
    {
        $this->join();
    }
}