ByJG\PHPThread\Handler\ParallelHandler

Complexity

Total Complexity

10

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getClassName()	0	3	1
A	waitFinish()	0	4	3
A	execute()	0	6	1
A	setClosure()	0	3	1
A	getResult()	0	3	1
A	stop()	0	3	1
A	isAlive()	0	3	2

<?php

namespace ByJG\PHPThread\Handler;

class ParallelHandler implements ThreadInterface
{
    protected $closure;
    protected $runtime;
    protected $future;

    public function execute()
    {
        $fnArgs = func_get_args();

        $this->runtime = new \parallel\Runtime();
        $this->future = $this->runtime->run($this->closure, $fnArgs);
    }

    public function getResult()
    {
        return $this->future->value();
    }

    public function stop($signal = SIGKILL, $wait = false)
    {
        $this->runtime->kill();
    }

    public function isAlive()
    {
        return !$this->future->cancelled() && !$this->future->done();
    }

    public function setClosure(\Closure $closure)
    {
        $this->closure = $closure;
    }

    public function waitFinish()
    {
        while (!$this->future->cancelled() && !$this->future->done()) {
            sleep(1);
        }
    }

    public function getClassName()
    {
        return ParallelHandler::class;
    }
}