AliceMajere / wonderland-thread

src/Mediator/Listener/ListenerInterface.php

Indentation +9 added lines, -9 removed lines

@@ -6,15 +6,15 @@
 
 interface ListenerInterface
 {
-	/**
-	 * @return array
-	 */
-	public function getEventMapping(): array;
+    /**
+     * @return array
+     */
+    public function getEventMapping(): array;
 
-	/**
-	 * @param EventInterface $event
-	 * @return void
-	 */
-	public function notify(EventInterface $event);
+    /**
+     * @param EventInterface $event
+     * @return void
+     */
+    public function notify(EventInterface $event);
 
 }

src/AbstractThreadPoolMediator.php

Indentation +49 added lines, -49 removed lines

@@ -8,54 +8,54 @@
 
 abstract class AbstractThreadPoolMediator
 {
-	/** @var Mediator */
-	private $mediator;
-
-	/**
-	 * @return Mediator
-	 */
-	protected function getMediator()
-	{
-		return $this->mediator;
-	}
-
-	/**
-	 * ThreadPoolMediator constructor.
-	 */
-	public function __construct()
-	{
-		$this->mediator = new Mediator();
-	}
-
-	/**
-	 * @param ListenerInterface $listener
-	 * @return AbstractThreadPoolMediator
-	 */
-	public function addListener(ListenerInterface $listener): self
-	{
-		$this->mediator->addListener($listener);
-
-		return $this;
-	}
-
-	/**
-	 * @param ListenerInterface $listener
-	 * @return AbstractThreadPoolMediator
-	 */
-	public function removeListener(ListenerInterface $listener): self
-	{
-		$this->mediator->removeListener($listener);
-
-		return $this;
-	}
-
-	/**
-	 * @param string              $eventName
-	 * @param AbstractThread|null $thread
-	 */
-	protected function notify(string $eventName, ?AbstractThread $thread = null)
-	{
-		$this->getMediator()->notify(EventPoolFactory::create($eventName, $this, $thread));
-	}
+    /** @var Mediator */
+    private $mediator;
+
+    /**
+     * @return Mediator
+     */
+    protected function getMediator()
+    {
+        return $this->mediator;
+    }
+
+    /**
+     * ThreadPoolMediator constructor.
+     */
+    public function __construct()
+    {
+        $this->mediator = new Mediator();
+    }
+
+    /**
+     * @param ListenerInterface $listener
+     * @return AbstractThreadPoolMediator
+     */
+    public function addListener(ListenerInterface $listener): self
+    {
+        $this->mediator->addListener($listener);
+
+        return $this;
+    }
+
+    /**
+     * @param ListenerInterface $listener
+     * @return AbstractThreadPoolMediator
+     */
+    public function removeListener(ListenerInterface $listener): self
+    {
+        $this->mediator->removeListener($listener);
+
+        return $this;
+    }
+
+    /**
+     * @param string              $eventName
+     * @param AbstractThread|null $thread
+     */
+    protected function notify(string $eventName, ?AbstractThread $thread = null)
+    {
+        $this->getMediator()->notify(EventPoolFactory::create($eventName, $this, $thread));
+    }
 
 }

src/Event/PoolEvent.php

Indentation +181 added lines, -181 removed lines

@@ -7,186 +7,186 @@
 
 class PoolEvent 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 AbstractThread $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 PoolEvent
-	 */
-	public function setEventName(string $eventName): self
-	{
-		$this->eventName = $eventName;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getThreadNb(): int
-	{
-		return $this->threadNb;
-	}
-
-	/**
-	 * @param int $threadNb
-	 * @return PoolEvent
-	 */
-	public function setThreadNb(int $threadNb): self
-	{
-		$this->threadNb = $threadNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getThreadDoneNb(): int
-	{
-		return $this->threadDoneNb;
-	}
-
-	/**
-	 * @param int $threadDoneNb
-	 * @return PoolEvent
-	 */
-	public function setThreadDoneNb(int $threadDoneNb): self
-	{
-		$this->threadDoneNb = $threadDoneNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getThreadLeftNb(): int
-	{
-		return $this->threadLeftNb;
-	}
-
-	/**
-	 * @param int $threadLeftNb
-	 * @return PoolEvent
-	 */
-	public function setThreadLeftNb(int $threadLeftNb): self
-	{
-		$this->threadLeftNb = $threadLeftNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getMaxRunningThreadNb(): int
-	{
-		return $this->maxRunningThreadNb;
-	}
-
-	/**
-	 * @param int $maxRunningThreadNb
-	 * @return PoolEvent
-	 */
-	public function setMaxRunningThreadNb(int $maxRunningThreadNb): self
-	{
-		$this->maxRunningThreadNb = $maxRunningThreadNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return int
-	 */
-	public function getRunningThreadNb(): int
-	{
-		return $this->runningThreadNb;
-	}
-
-	/**
-	 * @param int $runningThreadNb
-	 * @return PoolEvent
-	 */
-	public function setRunningThreadNb(int $runningThreadNb): self
-	{
-		$this->runningThreadNb = $runningThreadNb;
-
-		return $this;
-	}
-
-	/**
-	 * @return AbstractThread
-	 */
-	public function getThread(): ?AbstractThread
-	{
-		return $this->thread;
-	}
-
-	/**
-	 * @param AbstractThread|null $thread
-	 * @return $this
-	 */
-	public function setThread(AbstractThread $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 AbstractThread $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 PoolEvent
+     */
+    public function setEventName(string $eventName): self
+    {
+        $this->eventName = $eventName;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getThreadNb(): int
+    {
+        return $this->threadNb;
+    }
+
+    /**
+     * @param int $threadNb
+     * @return PoolEvent
+     */
+    public function setThreadNb(int $threadNb): self
+    {
+        $this->threadNb = $threadNb;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getThreadDoneNb(): int
+    {
+        return $this->threadDoneNb;
+    }
+
+    /**
+     * @param int $threadDoneNb
+     * @return PoolEvent
+     */
+    public function setThreadDoneNb(int $threadDoneNb): self
+    {
+        $this->threadDoneNb = $threadDoneNb;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getThreadLeftNb(): int
+    {
+        return $this->threadLeftNb;
+    }
+
+    /**
+     * @param int $threadLeftNb
+     * @return PoolEvent
+     */
+    public function setThreadLeftNb(int $threadLeftNb): self
+    {
+        $this->threadLeftNb = $threadLeftNb;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getMaxRunningThreadNb(): int
+    {
+        return $this->maxRunningThreadNb;
+    }
+
+    /**
+     * @param int $maxRunningThreadNb
+     * @return PoolEvent
+     */
+    public function setMaxRunningThreadNb(int $maxRunningThreadNb): self
+    {
+        $this->maxRunningThreadNb = $maxRunningThreadNb;
+
+        return $this;
+    }
+
+    /**
+     * @return int
+     */
+    public function getRunningThreadNb(): int
+    {
+        return $this->runningThreadNb;
+    }
+
+    /**
+     * @param int $runningThreadNb
+     * @return PoolEvent
+     */
+    public function setRunningThreadNb(int $runningThreadNb): self
+    {
+        $this->runningThreadNb = $runningThreadNb;
+
+        return $this;
+    }
+
+    /**
+     * @return AbstractThread
+     */
+    public function getThread(): ?AbstractThread
+    {
+        return $this->thread;
+    }
+
+    /**
+     * @param AbstractThread|null $thread
+     * @return $this
+     */
+    public function setThread(AbstractThread $thread = null): self
+    {
+        $this->thread = $thread;
+
+        return $this;
+    }
 
 }

tests/unit/Factory/EventPoolFactoryTest.php

Indentation +13 added lines, -13 removed lines

@@ -18,19 +18,19 @@
 class EventPoolFactoryTest extends TestCase
 {
 
-	public function test_create()
-	{
-		$pool = new ThreadPool();
-		$thread = new SuccessThread('unit-test');
-		$event = new PoolEvent('unit-test');
-		$factoryEvent = EventPoolFactory::create('unit-test', $pool, $thread);
+    public function test_create()
+    {
+        $pool = new ThreadPool();
+        $thread = new SuccessThread('unit-test');
+        $event = new PoolEvent('unit-test');
+        $factoryEvent = EventPoolFactory::create('unit-test', $pool, $thread);
 
-		$this->assertSame($event->getEventName(), $factoryEvent->getEventName());
-		$this->assertSame($event->getThreadLeftNb(), $factoryEvent->getThreadLeftNb());
-		$this->assertSame($event->getMaxRunningThreadNb(), $factoryEvent->getMaxRunningThreadNb());
-		$this->assertSame($event->getRunningThreadNb(), $factoryEvent->getRunningThreadNb());
-		$this->assertSame($event->getThreadDoneNb(), $factoryEvent->getThreadDoneNb());
-		$this->assertSame($event->getThreadNb(), $factoryEvent->getThreadNb());
-	}
+        $this->assertSame($event->getEventName(), $factoryEvent->getEventName());
+        $this->assertSame($event->getThreadLeftNb(), $factoryEvent->getThreadLeftNb());
+        $this->assertSame($event->getMaxRunningThreadNb(), $factoryEvent->getMaxRunningThreadNb());
+        $this->assertSame($event->getRunningThreadNb(), $factoryEvent->getRunningThreadNb());
+        $this->assertSame($event->getThreadDoneNb(), $factoryEvent->getThreadDoneNb());
+        $this->assertSame($event->getThreadNb(), $factoryEvent->getThreadNb());
+    }
 
 }

tests/unit/Implementation/SuccessThread.php

Indentation +26 added lines, -26 removed lines

@@ -7,31 +7,31 @@
 class SuccessThread extends AbstractThread
 {
 
-	public function method()
-	{
-		$this->notify(new TestEvent());
-
-		return self::EXIT_STATUS_SUCCESS;
-	}
-
-	/**
-	 * Return the name of the method to process during the thread
-	 *
-	 * @return string
-	 */
-	protected function getMethodName(): string
-	{
-		return 'method';
-	}
-
-	/**
-	 * Return the list of dependencies that will be passed as parameters of the method referenced by getMethodName
-	 *
-	 * @return array
-	 */
-	protected function getDependencies(): array
-	{
-		return ['toto'];
-	}
+    public function method()
+    {
+        $this->notify(new TestEvent());
+
+        return self::EXIT_STATUS_SUCCESS;
+    }
+
+    /**
+     * Return the name of the method to process during the thread
+     *
+     * @return string
+     */
+    protected function getMethodName(): string
+    {
+        return 'method';
+    }
+
+    /**
+     * Return the list of dependencies that will be passed as parameters of the method referenced by getMethodName
+     *
+     * @return array
+     */
+    protected function getDependencies(): array
+    {
+        return ['toto'];
+    }
 
 }

tests/unit/Implementation/ErrorThread.php

Indentation +22 added lines, -22 removed lines

@@ -7,29 +7,29 @@
 class ErrorThread extends AbstractThread
 {
 
-	public function method()
-	{
-		return null;
-	}
+    public function method()
+    {
+        return null;
+    }
 
-	/**
-	 * Return the name of the method to process during the thread
-	 *
-	 * @return string
-	 */
-	protected function getMethodName(): string
-	{
-		return 'method';
-	}
+    /**
+     * Return the name of the method to process during the thread
+     *
+     * @return string
+     */
+    protected function getMethodName(): string
+    {
+        return 'method';
+    }
 
-	/**
-	 * Return the list of dependencies that will be passed as parameters of the method referenced by getMethodName
-	 *
-	 * @return array
-	 */
-	protected function getDependencies(): array
-	{
-		return ['toto'];
-	}
+    /**
+     * Return the list of dependencies that will be passed as parameters of the method referenced by getMethodName
+     *
+     * @return array
+     */
+    protected function getDependencies(): array
+    {
+        return ['toto'];
+    }
 
 }

tests/unit/Implementation/TestListener.php

Indentation +15 added lines, -15 removed lines

@@ -8,22 +8,22 @@
 class TestListener extends AbstractListener
 {
 
-	/**
-	 * @return array
-	 */
-	public function getEventMapping(): array
-	{
-		return [
-			PoolEvent::POOL_NEW_THREAD => 'onNewThread'
-		];
-	}
+    /**
+     * @return array
+     */
+    public function getEventMapping(): array
+    {
+        return [
+            PoolEvent::POOL_NEW_THREAD => 'onNewThread'
+        ];
+    }
 
-	/**
-	 * @param PoolEvent $event
-	 */
-	public function onNewThread(PoolEvent $event)
-	{
+    /**
+     * @param PoolEvent $event
+     */
+    public function onNewThread(PoolEvent $event)
+    {
 
-	}
+    }
 
 }

tests/unit/Implementation/TestEvent.php

Indentation +7 added lines, -7 removed lines

@@ -7,12 +7,12 @@
 class TestEvent implements EventInterface
 {
 
-	/**
-	 * @return string
-	 */
-	public function getEventName(): string
-	{
-		return 'test-unit-event';
-	}
+    /**
+     * @return string
+     */
+    public function getEventName(): string
+    {
+        return 'test-unit-event';
+    }
 
 }

tests/unit/Implementation/ExceptionThread.php

Indentation +18 added lines, -18 removed lines

@@ -7,24 +7,24 @@
 class ExceptionThread extends AbstractThread
 {
 
-	/**
-	 * Return the name of the method to process during the thread
-	 *
-	 * @return string
-	 */
-	protected function getMethodName(): string
-	{
-		return 'method';
-	}
+    /**
+     * Return the name of the method to process during the thread
+     *
+     * @return string
+     */
+    protected function getMethodName(): string
+    {
+        return 'method';
+    }
 
-	/**
-	 * Return the list of dependencies that will be passed as parameters of the method referenced by getMethodName
-	 *
-	 * @return array
-	 */
-	protected function getDependencies(): array
-	{
-		return ['toto'];
-	}
+    /**
+     * Return the list of dependencies that will be passed as parameters of the method referenced by getMethodName
+     *
+     * @return array
+     */
+    protected function getDependencies(): array
+    {
+        return ['toto'];
+    }
 
 }