SynchronousProcess::start() - Code Metrics - Inspection of "Configurable executable" - spatie/async - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#111)

by Alexander

created 2020-04-14 13:00 UTC

SynchronousProcess::start() A

↳ Parent: SynchronousProcess

Complexity

Conditions	3
Paths	6

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
nc	6
nop	0
dl	0
loc	14
rs	9.7998
c	0
b	0
f	0

<?php

namespace Spatie\Async\Process;

use Spatie\Async\Pool;
use Spatie\Async\Task;
use Throwable;

class SynchronousProcess implements Runnable
{
    protected $id;

    protected $task;

    protected $output;
    protected $errorOutput;
    protected $executionTime;

    use ProcessCallbacks;

    public function __construct(callable $task, int $id)
    {
        $this->id = $id;
        $this->task = $task;
    }

    public static function create(callable $task, int $id): self
    {
        return new self($task, $id);
    }

    public function getId(): int
    {
        return $this->id;
    }

    public function getPid(): ?int
    {
        return $this->getId();
    }

    public function start()
    {
        $startTime = microtime(true);

        try {
            $this->output = $this->task instanceof Task
                ? $this->task->run()
                : call_user_func($this->task);
        } catch (Throwable $throwable) {
            $this->errorOutput = $throwable;
        } finally {
            $this->executionTime = microtime(true) - $startTime;
        }
    }

    public function stop()
    {
    }

    public function getOutput()
    {
        return $this->output;
    }

    public function getErrorOutput()
    {
        return $this->errorOutput;
    }

    public function getCurrentExecutionTime(): float
    {
        return $this->executionTime;
    }

    protected function resolveErrorOutput(): Throwable
    {
        return $this->getErrorOutput();
    }

    public function withBinary(string $binary = Pool::DEFAULT_PHP_BINARY): self
    {
        return $this;
    }
}


1			<?php
2
3			namespace Spatie\Async\Process;
4
5			use Spatie\Async\Pool;
6			use Spatie\Async\Task;
7			use Throwable;
8
9			class SynchronousProcess implements Runnable
10			{
11			protected $id;
12
13			protected $task;
14
15			protected $output;
16			protected $errorOutput;
17			protected $executionTime;
18
19			use ProcessCallbacks;
20
21			public function __construct(callable $task, int $id)
22			{
23			$this->id = $id;
24			$this->task = $task;
25			}
26
27			public static function create(callable $task, int $id): self
28			{
29			return new self($task, $id);
30			}
31
32			public function getId(): int
33			{
34			return $this->id;
35			}
36
37			public function getPid(): ?int
38			{
39			return $this->getId();
40			}
41
42			public function start()
43			{
44			$startTime = microtime(true);
45
46			try {
47			$this->output = $this->task instanceof Task
48			? $this->task->run()
49			: call_user_func($this->task);
50			} catch (Throwable $throwable) {
51			$this->errorOutput = $throwable;
52			} finally {
53			$this->executionTime = microtime(true) - $startTime;
54			}
55			}
56
57			public function stop()
58			{
59			}
60
61			public function getOutput()
62			{
63			return $this->output;
64			}
65
66			public function getErrorOutput()
67			{
68			return $this->errorOutput;
69			}
70
71			public function getCurrentExecutionTime(): float
72			{
73			return $this->executionTime;
74			}
75
76			protected function resolveErrorOutput(): Throwable
77			{
78			return $this->getErrorOutput();
79			}
80
81			public function withBinary(string $binary = Pool::DEFAULT_PHP_BINARY): self
82			{
83			return $this;
84			}
85			}
86

spatie / async

GitHub Access Token became invalid

Pull Request — master (#111)

SynchronousProcess::start() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like