Wonderland\Thread\Thread

Complexity

Total Complexity

9

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	13	3
A	setPid()	0	5	1
A	setCallback()	0	5	1
A	getPid()	0	3	1
A	setProcessName()	0	5	1
A	getProcessName()	0	3	1
A	getCallback()	0	3	1

<?php

namespace Wonderland\Thread;

use Wonderland\Thread\Exception\ThreadException;

class Thread
{
	const EXIT_STATUS_SUCCESS = 0;
	const EXIT_STATUS_ERROR = 1;

	/** @var int $pid */
	private $pid;

	/** @var string $processName */
	private $processName;

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

	/**
	 * @return int|null
	 */
	public function getPid(): ?int
	{
		return $this->pid;
	}

	/**
	 * @param int $pid
	 * @return Thread
	 */
	public function setPid(int $pid): self
	{
		$this->pid = $pid;

		return $this;
	}

	/**
	 * @return string
	 */
	public function getProcessName(): ?string
	{
		return $this->processName;
	}

	/**
	 * @param string $processName
	 * @return Thread
	 */
	public function setProcessName(string $processName): self
	{
		$this->processName = $processName;

		return $this;
	}

	/**
	 * @return callable
	 */
	public function getCallback(): ?callable
	{
		return $this->callback;
	}

	/**
	 * @param callable $callback
	 * @return Thread
	 */
	public function setCallback(callable $callback): self
	{
		$this->callback = $callback;

		return $this;
	}

	/**
	 * @param string $processName
	 * @return int
	 * @throws ThreadException
	 */
	public function run(string $processName): int
	{
		if (null === $this->callback) {
			throw new ThreadException('No callback function defined for the thread');
		}

		$status = ($this->callback)($processName);

		if (null === $status) {
			throw new ThreadException('Error. You must return a process status in your callback function');
		}

		return $status;
	}

}