AliceMajere / wonderland-thread

src/Mediator/Listener/Listener.php

Indentation +52 added lines, -52 removed lines

@@ -6,57 +6,57 @@
 
 class Listener implements ListenerInterface
 {
-	/** @var string $eventName */
-	private $eventName;
-
-	/** @var callable $callback */
-	private $callback;
-
-	/**
-	 * Listener constructor.
-	 * @param string $eventName
-	 * @param callable|null $callback
-	 */
-	public function __construct(string $eventName, callable $callback = null)
-	{
-		$this->eventName = $eventName;
-		$this->callback = $callback;
-	}
-
-	/**
-	 * @inheritDoc
-	 */
-	public function getEventName(): string
-	{
-		return $this->eventName;
-	}
-
-	/**
-	 * @inheritDoc
-	 */
-	public function setEventName(string $eventName): self
-	{
-		$this->eventName = $eventName;
-
-		return $this;
-	}
-
-	/**
-	 * @inheritDoc
-	 */
-	public function setCallback(callable $callback): ListenerInterface
-	{
-		$this->callback = $callback;
-
-		return $this;
-	}
-
-	/**
-	 * @inheritDoc
-	 */
-	public function notify(EventInterface $event)
-	{
-		($this->callback)($event);
-	}
+    /** @var string $eventName */
+    private $eventName;
+
+    /** @var callable $callback */
+    private $callback;
+
+    /**
+     * Listener constructor.
+     * @param string $eventName
+     * @param callable|null $callback
+     */
+    public function __construct(string $eventName, callable $callback = null)
+    {
+        $this->eventName = $eventName;
+        $this->callback = $callback;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function getEventName(): string
+    {
+        return $this->eventName;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function setEventName(string $eventName): self
+    {
+        $this->eventName = $eventName;
+
+        return $this;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function setCallback(callable $callback): ListenerInterface
+    {
+        $this->callback = $callback;
+
+        return $this;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function notify(EventInterface $event)
+    {
+        ($this->callback)($event);
+    }
 
 }

src/ThreadPool.php

Indentation +265 added lines, -265 removed lines

@@ -7,270 +7,270 @@
 
 class ThreadPool extends AbstractThreadPoolMediator
 {
-	// 0.2s
-	private const SLEEP_TIME_MS = 50000;
-
-	/** @var Thread[] $childs */
-	private $threads;
-
-	/** @var Thread[] $toRunThreads */
-	private $toRunThreads;
-
-	/** @var Thread[] $runningChilds */
-	private $runningThreads;
-
-	/** @var bool $isRunning */
-	private $isRunning;
-
-	/** @var int $maxRunningThreadNb */
-	private $maxRunningThreadNb;
-
-	/**
-	 * ThreadPool constructor.
-	 */
-	public function __construct()
-	{
-		parent::__construct();
-		$this->threads = [];
-		$this->runningThreads = [];
-		$this->toRunThreads = [];
-		$this->isRunning = false;
-		$this->maxRunningThreadNb = 0;
-	}
-
-	/**
-	 *
-	 */
-	public function __destruct()
-	{
-		pcntl_waitpid(-1, $status, WNOHANG);
-	}
-
-	/**
-	 * @return Thread[]
-	 */
-	public function getThreads(): array
-	{
-		return $this->threads;
-	}
-
-	/**
-	 * @param Thread[] $threads
-	 * @return ThreadPool
-	 */
-	public function setThreads(array $threads): self
-	{
-		$this->threads = $threads;
-
-		return $this;
-	}
-
-	/**
-	 * @param Thread $thread
-	 * @return ThreadPool
-	 */
-	public function addThread(Thread $thread): self
-	{
-		$this->threads[] = $thread;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getMaxRunningThreadNb(): int
-	{
-		return $this->maxRunningThreadNb;
-	}
-
-	/**
-	 * @param int $maxRunningThreadNb
-	 * @return ThreadPool
-	 */
-	public function setMaxRunningThreadNb(int $maxRunningThreadNb): self
-	{
-		$this->maxRunningThreadNb = $maxRunningThreadNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return Thread[]
-	 */
-	public function getToRunThreads(): array
-	{
-		return $this->toRunThreads;
-	}
-
-	/**
-	 * @return Thread[]
-	 */
-	public function getRunningThreads(): array
-	{
-		return $this->runningThreads;
-	}
-
-	/**
-	 * @throws ThreadException
-	 */
-	public function run()
-	{
-		$this->checkEnv();
-		$this->initRun();
-
-		while ($this->isRunningThreads()) {
-			$this->waitOnThreads();
-		}
-
-		$this->resetRun();
-	}
-
-	/**
-	 * @return bool
-	 * @throws ThreadException
-	 */
-	private function isRunningThreads(): bool
-	{
-		if (count($this->toRunThreads) > 0) {
-			while (count($this->runningThreads) < $this->maxRunningThreadNb && count($this->toRunThreads) > 0) {
-				$this->createThreadProcess(array_shift($this->toRunThreads));
-			}
-		}
-
-		return count($this->runningThreads) > 0;
-	}
-
-	/**
-	 * can't test some part of it this since we can't unit-test in web and we're never in a child
-	 * process when pid 0 when unit-testing since the coverage is done by the parent thread
-	 * @param Thread $thread
-	 * @throws ThreadException
-	 */
-	private function createThreadProcess(Thread $thread)
-	{
-		$pid = pcntl_fork();
-
-		switch ($pid) {
-			case -1: //error forking
-				// @codeCoverageIgnoreStart
-				throw new ThreadException('Error while trying to fork. Check your server installation');
-				// @codeCoverageIgnoreEnd
-			case 0: // child
-				// @codeCoverageIgnoreStart
-				$this->processThread($thread);
-				break;
-				// @codeCoverageIgnoreEnd
-			default: //parent
-				$thread->setPid($pid);
-				$this->runningThreads[] = $thread;
-				$this->notify(Event::POOL_NEW_THREAD, $thread);
-				$this->startRunStatus();
-		}
-	}
-
-	/**
-	 *
-	 */
-	private function waitOnThreads()
-	{
-		$this->notify(Event::POOL_PRE_WAIT_TICK);
-		foreach ($this->runningThreads as $k => $thread) {
-
-			$res = pcntl_waitpid($thread->getPid(), $status, WNOHANG);
-			$this->notify(Event::POOL_WAIT_TICK_PID);
-
-			if ($res === -1 || $res > 0) {
-				$this->notify(Event::POOL_WAIT_TICK_PID_REMOVED, $thread);
-				unset($this->runningThreads[$k]);
-			}
-
-		}
-		$this->notify(Event::POOL_POST_WAIT_TICK);
-
-		usleep(self::SLEEP_TIME_MS);
-	}
-
-	/**
-	 * @codeCoverageIgnore Can't test since this is only run in a child thread.. which doesnt' go throug the
-	 * unit-test coverage which is only done in the main process
-	 * @param Thread $thread
-	 * @throws ThreadException
-	 */
-	private function processThread(Thread $thread)
-	{
-		$this->notify(Event::THREAD_PRE_PROCESS, $thread);
-		$response = $thread->run($thread->getProcessName());
-		$this->notify(Event::THREAD_POST_PROCESS, $thread);
-
-		switch ($response) {
-			case Thread::EXIT_STATUS_SUCCESS:
-				$this->notify(Event::THREAD_EXIT_SUCCESS, $thread);
-				break;
-			case Thread::EXIT_STATUS_ERROR:
-				$this->notify(Event::THREAD_EXIT_ERROR, $thread);
-				break;
-			default:
-				$this->notify(Event::THREAD_EXIT_UNKNOWN, $thread);
-		}
-
-		exit($response);
-	}
-
-	/**
-	 * Can't test the exception is not in cli since php-unit is only run in cli environment
-	 * @throws ThreadException
-	 */
-	private function checkEnv()
-	{
-		if (false === $this->isCli()) {
-			// @codeCoverageIgnoreStart
-			throw new ThreadException('Error. It is not safe to use process forking in other way than php-cli');
-			// @codeCoverageIgnoreEnd
-		}
-		if (0 === count($this->threads)) {
-			throw new ThreadException('Error. Can\'t run child threads processes without any added in the Pool');
-		}
-	}
-
-	/**
-	 *
-	 */
-	private function initRun()
-	{
-		$this->resetRun();
-	}
-
-	/**
-	 * @return bool
-	 */
-	private function isCli(): bool
-	{
-		return PHP_SAPI === 'cli';
-	}
-
-	/**
-	 *
-	 */
-	private function startRunStatus()
-	{
-		if (false === $this->isRunning) {
-			$this->notify(Event::POOL_RUN_START);
-			$this->isRunning = true;
-		}
-	}
-
-	/**
-	 *
-	 */
-	private function resetRun()
-	{
-		if (true === $this->isRunning) {
-			$this->notify(Event::POOL_RUN_STOP);
-		}
-		$this->isRunning = false;
-		$this->toRunThreads = $this->threads;
-		$this->runningThreads = [];
-	}
+    // 0.2s
+    private const SLEEP_TIME_MS = 50000;
+
+    /** @var Thread[] $childs */
+    private $threads;
+
+    /** @var Thread[] $toRunThreads */
+    private $toRunThreads;
+
+    /** @var Thread[] $runningChilds */
+    private $runningThreads;
+
+    /** @var bool $isRunning */
+    private $isRunning;
+
+    /** @var int $maxRunningThreadNb */
+    private $maxRunningThreadNb;
+
+    /**
+     * ThreadPool constructor.
+     */
+    public function __construct()
+    {
+        parent::__construct();
+        $this->threads = [];
+        $this->runningThreads = [];
+        $this->toRunThreads = [];
+        $this->isRunning = false;
+        $this->maxRunningThreadNb = 0;
+    }
+
+    /**
+     *
+     */
+    public function __destruct()
+    {
+        pcntl_waitpid(-1, $status, WNOHANG);
+    }
+
+    /**
+     * @return Thread[]
+     */
+    public function getThreads(): array
+    {
+        return $this->threads;
+    }
+
+    /**
+     * @param Thread[] $threads
+     * @return ThreadPool
+     */
+    public function setThreads(array $threads): self
+    {
+        $this->threads = $threads;
+
+        return $this;
+    }
+
+    /**
+     * @param Thread $thread
+     * @return ThreadPool
+     */
+    public function addThread(Thread $thread): self
+    {
+        $this->threads[] = $thread;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getMaxRunningThreadNb(): int
+    {
+        return $this->maxRunningThreadNb;
+    }
+
+    /**
+     * @param int $maxRunningThreadNb
+     * @return ThreadPool
+     */
+    public function setMaxRunningThreadNb(int $maxRunningThreadNb): self
+    {
+        $this->maxRunningThreadNb = $maxRunningThreadNb;
+
+        return $this;
+    }
+
+    /**
+     * @return Thread[]
+     */
+    public function getToRunThreads(): array
+    {
+        return $this->toRunThreads;
+    }
+
+    /**
+     * @return Thread[]
+     */
+    public function getRunningThreads(): array
+    {
+        return $this->runningThreads;
+    }
+
+    /**
+     * @throws ThreadException
+     */
+    public function run()
+    {
+        $this->checkEnv();
+        $this->initRun();
+
+        while ($this->isRunningThreads()) {
+            $this->waitOnThreads();
+        }
+
+        $this->resetRun();
+    }
+
+    /**
+     * @return bool
+     * @throws ThreadException
+     */
+    private function isRunningThreads(): bool
+    {
+        if (count($this->toRunThreads) > 0) {
+            while (count($this->runningThreads) < $this->maxRunningThreadNb && count($this->toRunThreads) > 0) {
+                $this->createThreadProcess(array_shift($this->toRunThreads));
+            }
+        }
+
+        return count($this->runningThreads) > 0;
+    }
+
+    /**
+     * can't test some part of it this since we can't unit-test in web and we're never in a child
+     * process when pid 0 when unit-testing since the coverage is done by the parent thread
+     * @param Thread $thread
+     * @throws ThreadException
+     */
+    private function createThreadProcess(Thread $thread)
+    {
+        $pid = pcntl_fork();
+
+        switch ($pid) {
+            case -1: //error forking
+                // @codeCoverageIgnoreStart
+                throw new ThreadException('Error while trying to fork. Check your server installation');
+                // @codeCoverageIgnoreEnd
+            case 0: // child
+                // @codeCoverageIgnoreStart
+                $this->processThread($thread);
+                break;
+                // @codeCoverageIgnoreEnd
+            default: //parent
+                $thread->setPid($pid);
+                $this->runningThreads[] = $thread;
+                $this->notify(Event::POOL_NEW_THREAD, $thread);
+                $this->startRunStatus();
+        }
+    }
+
+    /**
+     *
+     */
+    private function waitOnThreads()
+    {
+        $this->notify(Event::POOL_PRE_WAIT_TICK);
+        foreach ($this->runningThreads as $k => $thread) {
+
+            $res = pcntl_waitpid($thread->getPid(), $status, WNOHANG);
+            $this->notify(Event::POOL_WAIT_TICK_PID);
+
+            if ($res === -1 || $res > 0) {
+                $this->notify(Event::POOL_WAIT_TICK_PID_REMOVED, $thread);
+                unset($this->runningThreads[$k]);
+            }
+
+        }
+        $this->notify(Event::POOL_POST_WAIT_TICK);
+
+        usleep(self::SLEEP_TIME_MS);
+    }
+
+    /**
+     * @codeCoverageIgnore Can't test since this is only run in a child thread.. which doesnt' go throug the
+     * unit-test coverage which is only done in the main process
+     * @param Thread $thread
+     * @throws ThreadException
+     */
+    private function processThread(Thread $thread)
+    {
+        $this->notify(Event::THREAD_PRE_PROCESS, $thread);
+        $response = $thread->run($thread->getProcessName());
+        $this->notify(Event::THREAD_POST_PROCESS, $thread);
+
+        switch ($response) {
+            case Thread::EXIT_STATUS_SUCCESS:
+                $this->notify(Event::THREAD_EXIT_SUCCESS, $thread);
+                break;
+            case Thread::EXIT_STATUS_ERROR:
+                $this->notify(Event::THREAD_EXIT_ERROR, $thread);
+                break;
+            default:
+                $this->notify(Event::THREAD_EXIT_UNKNOWN, $thread);
+        }
+
+        exit($response);
+    }
+
+    /**
+     * Can't test the exception is not in cli since php-unit is only run in cli environment
+     * @throws ThreadException
+     */
+    private function checkEnv()
+    {
+        if (false === $this->isCli()) {
+            // @codeCoverageIgnoreStart
+            throw new ThreadException('Error. It is not safe to use process forking in other way than php-cli');
+            // @codeCoverageIgnoreEnd
+        }
+        if (0 === count($this->threads)) {
+            throw new ThreadException('Error. Can\'t run child threads processes without any added in the Pool');
+        }
+    }
+
+    /**
+     *
+     */
+    private function initRun()
+    {
+        $this->resetRun();
+    }
+
+    /**
+     * @return bool
+     */
+    private function isCli(): bool
+    {
+        return PHP_SAPI === 'cli';
+    }
+
+    /**
+     *
+     */
+    private function startRunStatus()
+    {
+        if (false === $this->isRunning) {
+            $this->notify(Event::POOL_RUN_START);
+            $this->isRunning = true;
+        }
+    }
+
+    /**
+     *
+     */
+    private function resetRun()
+    {
+        if (true === $this->isRunning) {
+            $this->notify(Event::POOL_RUN_STOP);
+        }
+        $this->isRunning = false;
+        $this->toRunThreads = $this->threads;
+        $this->runningThreads = [];
+    }
 
 }

src/Factory/EventFactory.php

Indentation +17 added lines, -17 removed lines

@@ -10,23 +10,23 @@
 class EventFactory
 {
 
-	/**
-	 * @param string $eventName
-	 * @param ThreadPool|AbstractThreadPoolMediator $pool
-	 * @param Thread|null $thread
-	 * @return Event
-	 */
-	public static function create(string $eventName, AbstractThreadPoolMediator $pool, ?Thread $thread = null): Event
-	{
-		$event = new Event($eventName);
-		$event->setThreadNb(count($pool->getThreads()));
-		$event->setThreadDoneNb(count($pool->getThreads()) - count($pool->getToRunThreads()));
-		$event->setMaxRunningThreadNb($pool->getMaxRunningThreadNb());
-		$event->setThreadLeftNb(count($pool->getToRunThreads()));
-		$event->setRunningThreadNb(count($pool->getRunningThreads()));
-		$event->setThread($thread);
+    /**
+     * @param string $eventName
+     * @param ThreadPool|AbstractThreadPoolMediator $pool
+     * @param Thread|null $thread
+     * @return Event
+     */
+    public static function create(string $eventName, AbstractThreadPoolMediator $pool, ?Thread $thread = null): Event
+    {
+        $event = new Event($eventName);
+        $event->setThreadNb(count($pool->getThreads()));
+        $event->setThreadDoneNb(count($pool->getThreads()) - count($pool->getToRunThreads()));
+        $event->setMaxRunningThreadNb($pool->getMaxRunningThreadNb());
+        $event->setThreadLeftNb(count($pool->getToRunThreads()));
+        $event->setRunningThreadNb(count($pool->getRunningThreads()));
+        $event->setThread($thread);
 
-		return $event;
-	}
+        return $event;
+    }
 
 }

src/Factory/ThreadFactory.php

Indentation +12 added lines, -12 removed lines

@@ -7,18 +7,18 @@
 class ThreadFactory
 {
 
-	/**
-	 * @param $processName
-	 * @param callable $function
-	 * @return Thread
-	 */
-	public static function create(string $processName, callable $function): Thread
-	{
-		$thread = new Thread();
-		$thread->setCallback($function);
-		$thread->setProcessName($processName);
+    /**
+     * @param $processName
+     * @param callable $function
+     * @return Thread
+     */
+    public static function create(string $processName, callable $function): Thread
+    {
+        $thread = new Thread();
+        $thread->setCallback($function);
+        $thread->setProcessName($processName);
 
-		return $thread;
-	}
+        return $thread;
+    }
 
 }

src/Event/Event.php

Indentation +181 added lines, -181 removed lines

@@ -7,186 +7,186 @@
 
 class Event implements EventInterface
 {
-	const POOL_RUN_START = 'run_start';
-	const POOL_RUN_STOP = 'run_stop';
-	const POOL_NEW_THREAD = 'new_thread';
-	const POOL_PRE_WAIT_TICK = 'pre_wait_tick';
-	const POOL_POST_WAIT_TICK = 'post_wait_tick';
-	const POOL_WAIT_TICK_PID = 'wait_tick_pid';
-	const POOL_WAIT_TICK_PID_REMOVED = 'wait_tick_pid_removed';
-
-	const THREAD_PRE_PROCESS = 'pre_process';
-	const THREAD_POST_PROCESS = 'post_process';
-	const THREAD_EXIT_SUCCESS = 'exist_success';
-	const THREAD_EXIT_ERROR = 'exit_error';
-	const THREAD_EXIT_UNKNOWN = 'exit_unknown';
-
-	/** @var string $eventName */
-	private $eventName;
-
-	/** @var int $threadNb */
-	private $threadNb;
-
-	/** @var int $runningThreadNb */
-	private $runningThreadNb;
-
-	/** @var int $threadDoneNb */
-	private $threadDoneNb;
-
-	/** @var int $threadLeftNb */
-	private $threadLeftNb;
-
-	/** @var int $maxRunningThreadNb */
-	private $maxRunningThreadNb;
-
-	/** @var Thread $thread */
-	private $thread;
-
-	/**
-	 * ThreadPoolEvent constructor.
-	 * @param string $eventName
-	 */
-	public function __construct($eventName)
-	{
-		$this->eventName = $eventName;
-		$this->threadNb = 0;
-		$this->runningThreadNb = 0;
-		$this->threadDoneNb = 0;
-		$this->threadLeftNb = 0;
-		$this->maxRunningThreadNb = 0;
-	}
-
-	/**
-	 * @return string
-	 */
-	public function getEventName(): string
-	{
-		return $this->eventName;
-	}
-
-	/**
-	 * @param string $eventName
-	 * @return Event
-	 */
-	public function setEventName(string $eventName): self
-	{
-		$this->eventName = $eventName;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getThreadNb(): int
-	{
-		return $this->threadNb;
-	}
-
-	/**
-	 * @param int $threadNb
-	 * @return Event
-	 */
-	public function setThreadNb(int $threadNb): self
-	{
-		$this->threadNb = $threadNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getThreadDoneNb(): int
-	{
-		return $this->threadDoneNb;
-	}
-
-	/**
-	 * @param int $threadDoneNb
-	 * @return Event
-	 */
-	public function setThreadDoneNb(int $threadDoneNb): self
-	{
-		$this->threadDoneNb = $threadDoneNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getThreadLeftNb(): int
-	{
-		return $this->threadLeftNb;
-	}
-
-	/**
-	 * @param int $threadLeftNb
-	 * @return Event
-	 */
-	public function setThreadLeftNb(int $threadLeftNb): self
-	{
-		$this->threadLeftNb = $threadLeftNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getMaxRunningThreadNb(): int
-	{
-		return $this->maxRunningThreadNb;
-	}
-
-	/**
-	 * @param int $maxRunningThreadNb
-	 * @return Event
-	 */
-	public function setMaxRunningThreadNb(int $maxRunningThreadNb): self
-	{
-		$this->maxRunningThreadNb = $maxRunningThreadNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getRunningThreadNb(): int
-	{
-		return $this->runningThreadNb;
-	}
-
-	/**
-	 * @param int $runningThreadNb
-	 * @return Event
-	 */
-	public function setRunningThreadNb(int $runningThreadNb): self
-	{
-		$this->runningThreadNb = $runningThreadNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return Thread
-	 */
-	public function getThread(): ?Thread
-	{
-		return $this->thread;
-	}
-
-	/**
-	 * @param Thread|null $thread
-	 * @return $this
-	 */
-	public function setThread(Thread $thread = null): self
-	{
-		$this->thread = $thread;
-
-		return $this;
-	}
+    const POOL_RUN_START = 'run_start';
+    const POOL_RUN_STOP = 'run_stop';
+    const POOL_NEW_THREAD = 'new_thread';
+    const POOL_PRE_WAIT_TICK = 'pre_wait_tick';
+    const POOL_POST_WAIT_TICK = 'post_wait_tick';
+    const POOL_WAIT_TICK_PID = 'wait_tick_pid';
+    const POOL_WAIT_TICK_PID_REMOVED = 'wait_tick_pid_removed';
+
+    const THREAD_PRE_PROCESS = 'pre_process';
+    const THREAD_POST_PROCESS = 'post_process';
+    const THREAD_EXIT_SUCCESS = 'exist_success';
+    const THREAD_EXIT_ERROR = 'exit_error';
+    const THREAD_EXIT_UNKNOWN = 'exit_unknown';
+
+    /** @var string $eventName */
+    private $eventName;
+
+    /** @var int $threadNb */
+    private $threadNb;
+
+    /** @var int $runningThreadNb */
+    private $runningThreadNb;
+
+    /** @var int $threadDoneNb */
+    private $threadDoneNb;
+
+    /** @var int $threadLeftNb */
+    private $threadLeftNb;
+
+    /** @var int $maxRunningThreadNb */
+    private $maxRunningThreadNb;
+
+    /** @var Thread $thread */
+    private $thread;
+
+    /**
+     * ThreadPoolEvent constructor.
+     * @param string $eventName
+     */
+    public function __construct($eventName)
+    {
+        $this->eventName = $eventName;
+        $this->threadNb = 0;
+        $this->runningThreadNb = 0;
+        $this->threadDoneNb = 0;
+        $this->threadLeftNb = 0;
+        $this->maxRunningThreadNb = 0;
+    }
+
+    /**
+     * @return string
+     */
+    public function getEventName(): string
+    {
+        return $this->eventName;
+    }
+
+    /**
+     * @param string $eventName
+     * @return Event
+     */
+    public function setEventName(string $eventName): self
+    {
+        $this->eventName = $eventName;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getThreadNb(): int
+    {
+        return $this->threadNb;
+    }
+
+    /**
+     * @param int $threadNb
+     * @return Event
+     */
+    public function setThreadNb(int $threadNb): self
+    {
+        $this->threadNb = $threadNb;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getThreadDoneNb(): int
+    {
+        return $this->threadDoneNb;
+    }
+
+    /**
+     * @param int $threadDoneNb
+     * @return Event
+     */
+    public function setThreadDoneNb(int $threadDoneNb): self
+    {
+        $this->threadDoneNb = $threadDoneNb;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getThreadLeftNb(): int
+    {
+        return $this->threadLeftNb;
+    }
+
+    /**
+     * @param int $threadLeftNb
+     * @return Event
+     */
+    public function setThreadLeftNb(int $threadLeftNb): self
+    {
+        $this->threadLeftNb = $threadLeftNb;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getMaxRunningThreadNb(): int
+    {
+        return $this->maxRunningThreadNb;
+    }
+
+    /**
+     * @param int $maxRunningThreadNb
+     * @return Event
+     */
+    public function setMaxRunningThreadNb(int $maxRunningThreadNb): self
+    {
+        $this->maxRunningThreadNb = $maxRunningThreadNb;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getRunningThreadNb(): int
+    {
+        return $this->runningThreadNb;
+    }
+
+    /**
+     * @param int $runningThreadNb
+     * @return Event
+     */
+    public function setRunningThreadNb(int $runningThreadNb): self
+    {
+        $this->runningThreadNb = $runningThreadNb;
+
+        return $this;
+    }
+
+    /**
+     * @return Thread
+     */
+    public function getThread(): ?Thread
+    {
+        return $this->thread;
+    }
+
+    /**
+     * @param Thread|null $thread
+     * @return $this
+     */
+    public function setThread(Thread $thread = null): self
+    {
+        $this->thread = $thread;
+
+        return $this;
+    }
 
 }

tests/unit/Mediator/Listener/ListenerTest.php

Indentation +18 added lines, -18 removed lines

@@ -13,26 +13,26 @@
  */
 class ListenerTest extends TestCase
 {
-	/** @var Listener */
-	private $listener;
+    /** @var Listener */
+    private $listener;
 
-	/** @var callable */
-	private $callback;
+    /** @var callable */
+    private $callback;
 
-	public function setUp()
-	{
-		$this->callback = function(){
-  };
-		$this->listener = new Listener(Event::POOL_NEW_THREAD, $this->callback);
-	}
+    public function setUp()
+    {
+        $this->callback = function(){
+    };
+        $this->listener = new Listener(Event::POOL_NEW_THREAD, $this->callback);
+    }
 
-	public function test_listener()
-	{
-		$this->assertSame(Event::POOL_NEW_THREAD, $this->listener->getEventName());
-		$this->assertSame($this->listener, $this->listener->setEventName(Event::POOL_POST_WAIT_TICK));
-		$this->assertSame(Event::POOL_POST_WAIT_TICK, $this->listener->getEventName());
-		$this->assertSame($this->listener, $this->listener->setCallback($this->callback));
-		$this->listener->notify(new Event('test'));
-	}
+    public function test_listener()
+    {
+        $this->assertSame(Event::POOL_NEW_THREAD, $this->listener->getEventName());
+        $this->assertSame($this->listener, $this->listener->setEventName(Event::POOL_POST_WAIT_TICK));
+        $this->assertSame(Event::POOL_POST_WAIT_TICK, $this->listener->getEventName());
+        $this->assertSame($this->listener, $this->listener->setCallback($this->callback));
+        $this->listener->notify(new Event('test'));
+    }
 
 }

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
 
 	public function setUp()
 	{
-		$this->callback = function(){
+		$this->callback = function() {
   };
 		$this->listener = new Listener(Event::POOL_NEW_THREAD, $this->callback);
 	}

tests/unit/Mediator/MediatorTest.php

Indentation +18 added lines, -18 removed lines

@@ -14,25 +14,25 @@
  */
 class MediatorTest extends TestCase
 {
-	/** @var Mediator */
-	private $mediator;
+    /** @var Mediator */
+    private $mediator;
 
-	public function setUp()
-	{
-		$this->mediator = new Mediator();
-	}
+    public function setUp()
+    {
+        $this->mediator = new Mediator();
+    }
 
-	public function test_listeners()
-	{
-		$listener = new Listener(Event::POOL_NEW_THREAD, function() {
-  });
-		$this->assertSame([], $this->mediator->getListeners());
-		$this->assertSame($this->mediator, $this->mediator->addListener($listener));
-		$this->assertSame([Event::POOL_NEW_THREAD => [$listener]], $this->mediator->getListeners());
-		$this->assertSame($this->mediator, $this->mediator->removeListener(new Listener('fake', function(){
-  })));
-		$this->mediator->notify(Event::POOL_NEW_THREAD, new Event('unit-event'));
-		$this->assertSame($this->mediator, $this->mediator->removeListener($listener));
-	}
+    public function test_listeners()
+    {
+        $listener = new Listener(Event::POOL_NEW_THREAD, function() {
+    });
+        $this->assertSame([], $this->mediator->getListeners());
+        $this->assertSame($this->mediator, $this->mediator->addListener($listener));
+        $this->assertSame([Event::POOL_NEW_THREAD => [$listener]], $this->mediator->getListeners());
+        $this->assertSame($this->mediator, $this->mediator->removeListener(new Listener('fake', function(){
+    })));
+        $this->mediator->notify(Event::POOL_NEW_THREAD, new Event('unit-event'));
+        $this->assertSame($this->mediator, $this->mediator->removeListener($listener));
+    }
 
 }

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
 		$this->assertSame([], $this->mediator->getListeners());
 		$this->assertSame($this->mediator, $this->mediator->addListener($listener));
 		$this->assertSame([Event::POOL_NEW_THREAD => [$listener]], $this->mediator->getListeners());
-		$this->assertSame($this->mediator, $this->mediator->removeListener(new Listener('fake', function(){
+		$this->assertSame($this->mediator, $this->mediator->removeListener(new Listener('fake', function() {
   })));
 		$this->mediator->notify(Event::POOL_NEW_THREAD, new Event('unit-event'));
 		$this->assertSame($this->mediator, $this->mediator->removeListener($listener));

tests/unit/ThreadPoolTest.php

Indentation +86 added lines, -86 removed lines

@@ -17,96 +17,96 @@
  */
 class ThreadPoolTest extends TestCase
 {
-	/** @var ThreadPool */
-	private $threadPool;
-
-	protected function setUp()
-	{
-		$this->threadPool = new ThreadPool();
-	}
-
-	public function test_constructor_destructor()
-	{
-		$this->assertAttributeEquals([], 'threads', $this->threadPool);
-		$this->assertAttributeEquals([], 'runningThreads', $this->threadPool);
-		$this->assertAttributeEquals([], 'toRunThreads', $this->threadPool);
-		$this->assertAttributeEquals(false, 'isRunning', $this->threadPool);
-		$this->assertAttributeEquals(0, 'maxRunningThreadNb', $this->threadPool);
-		$this->assertSame(Mediator::class, get_class($this->threadPool->getMediator()));
-
-		unset($this->threadPool);
-	}
-
-	public function test_getThreads()
-	{
-		$threads = [new Thread()];
-		$this->assertSame($this->threadPool, $this->threadPool->setThreads($threads));
-		$this->assertSame($threads, $this->threadPool->getThreads());
-	}
-
-	public function test_addThread()
-	{
-		$thread = new Thread();
-		$this->assertSame($this->threadPool, $this->threadPool->addThread($thread));
-		$this->assertContains($thread, $this->threadPool->getThreads());
-	}
-
-	public function test_getMaxRunningThreadNb()
-	{
-		$this->assertSame(0, $this->threadPool->getMaxRunningThreadNb());
-	}
-
-	public function test_setMaxRunningThreadNb()
-	{
-		$this->assertSame($this->threadPool, $this->threadPool->setMaxRunningThreadNb(10));
-		$this->assertSame(10, $this->threadPool->getMaxRunningThreadNb());
-	}
-
-	public function test_getToRunThreads()
-	{
-		$this->assertSame([], $this->threadPool->getToRunThreads());
-	}
-
-	public function test_getRunningThreads()
-	{
-		$this->assertSame([], $this->threadPool->getRunningThreads());
-	}
-
-	/**
-	 * @throws \Wonderland\Thread\Exception\ThreadException
-	 */
-	public function test_run()
-	{
-		$thread = new Thread();
-		$thread->setCallback(function (){ return 0;
-
-  });
-		$thread->setProcessName('unitTest');
-		$threads = [];
-		$listener = new Listener(Event::POOL_NEW_THREAD, function (){
-  });
-
-		$this->threadPool->setMaxRunningThreadNb(10);
-		$this->assertSame($this->threadPool, $this->threadPool->addListener($listener));
-		for ($i = 0; $i < 20;
+    /** @var ThreadPool */
+    private $threadPool;
+
+    protected function setUp()
+    {
+        $this->threadPool = new ThreadPool();
+    }
+
+    public function test_constructor_destructor()
+    {
+        $this->assertAttributeEquals([], 'threads', $this->threadPool);
+        $this->assertAttributeEquals([], 'runningThreads', $this->threadPool);
+        $this->assertAttributeEquals([], 'toRunThreads', $this->threadPool);
+        $this->assertAttributeEquals(false, 'isRunning', $this->threadPool);
+        $this->assertAttributeEquals(0, 'maxRunningThreadNb', $this->threadPool);
+        $this->assertSame(Mediator::class, get_class($this->threadPool->getMediator()));
+
+        unset($this->threadPool);
+    }
+
+    public function test_getThreads()
+    {
+        $threads = [new Thread()];
+        $this->assertSame($this->threadPool, $this->threadPool->setThreads($threads));
+        $this->assertSame($threads, $this->threadPool->getThreads());
+    }
+
+    public function test_addThread()
+    {
+        $thread = new Thread();
+        $this->assertSame($this->threadPool, $this->threadPool->addThread($thread));
+        $this->assertContains($thread, $this->threadPool->getThreads());
+    }
+
+    public function test_getMaxRunningThreadNb()
+    {
+        $this->assertSame(0, $this->threadPool->getMaxRunningThreadNb());
+    }
+
+    public function test_setMaxRunningThreadNb()
+    {
+        $this->assertSame($this->threadPool, $this->threadPool->setMaxRunningThreadNb(10));
+        $this->assertSame(10, $this->threadPool->getMaxRunningThreadNb());
+    }
+
+    public function test_getToRunThreads()
+    {
+        $this->assertSame([], $this->threadPool->getToRunThreads());
+    }
+
+    public function test_getRunningThreads()
+    {
+        $this->assertSame([], $this->threadPool->getRunningThreads());
+    }
+
+    /**
+     * @throws \Wonderland\Thread\Exception\ThreadException
+     */
+    public function test_run()
+    {
+        $thread = new Thread();
+        $thread->setCallback(function (){ return 0;
+
+    });
+        $thread->setProcessName('unitTest');
+        $threads = [];
+        $listener = new Listener(Event::POOL_NEW_THREAD, function (){
+    });
+
+        $this->threadPool->setMaxRunningThreadNb(10);
+        $this->assertSame($this->threadPool, $this->threadPool->addListener($listener));
+        for ($i = 0; $i < 20;
 $i++) { $threads[] = clone $thread;
-		}
-		$this->assertSame($this->threadPool, $this->threadPool->addThread($thread));
-		$this->assertSame($this->threadPool, $this->threadPool->setThreads($threads));
+        }
+        $this->assertSame($this->threadPool, $this->threadPool->addThread($thread));
+        $this->assertSame($this->threadPool, $this->threadPool->setThreads($threads));
 
-		$this->threadPool->run();
+        $this->threadPool->run();
 
-		$this->assertSame($this->threadPool, $this->threadPool->removeListener($listener));
-	}
+        $this->assertSame($this->threadPool, $this->threadPool->removeListener($listener));
+    }
 
-	/**
-	 * @throws ThreadException
-	 */
-	public function test_run_exception()
-	{
-		$this->expectException(ThreadException::class);
-		$this->threadPool->run();
+    /**
+     * @throws ThreadException
+     */
+    public function test_run_exception()
+    {
+        $this->expectException(ThreadException::class);
+        $this->threadPool->run();
 
-	}
+    }
 
 }

Spacing +2 added lines, -2 removed lines

@@ -78,12 +78,12 @@
 	public function test_run()
 	{
 		$thread = new Thread();
-		$thread->setCallback(function (){ return 0;
+		$thread->setCallback(function() { return 0;
 
   });
 		$thread->setProcessName('unitTest');
 		$threads = [];
-		$listener = new Listener(Event::POOL_NEW_THREAD, function (){
+		$listener = new Listener(Event::POOL_NEW_THREAD, function() {
   });
 
 		$this->threadPool->setMaxRunningThreadNb(10);

tests/unit/Factory/ThreadFactoryTest.php

Indentation +10 added lines, -10 removed lines

@@ -14,16 +14,16 @@
 class ThreadFactoryTest extends TestCase
 {
 
-	public function test_create()
-	{
-		$callback = function(){
-  };
-		$thread = new Thread();
-		$thread->setProcessName('unit-test');
-		$thread->setCallback($callback);
+    public function test_create()
+    {
+        $callback = function(){
+    };
+        $thread = new Thread();
+        $thread->setProcessName('unit-test');
+        $thread->setCallback($callback);
 
-		$this->assertSame($thread->getCallback(), ThreadFactory::create('unit-test', $callback)->getCallback());
-		$this->assertSame($thread->getProcessName(), ThreadFactory::create('unit-test', $callback)->getProcessName());
-	}
+        $this->assertSame($thread->getCallback(), ThreadFactory::create('unit-test', $callback)->getCallback());
+        $this->assertSame($thread->getProcessName(), ThreadFactory::create('unit-test', $callback)->getProcessName());
+    }
 
 }

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
 
 	public function test_create()
 	{
-		$callback = function(){
+		$callback = function() {
   };
 		$thread = new Thread();
 		$thread->setProcessName('unit-test');