+started validating concepts pre-rearchitecting of BaseJob

-removed references to pthreads
*reconfigured autoloading
*tuned testing configuration

Author: feamsr00

.gitattributes

@@ -21,5 +21,7 @@ src/Supervisor.php -text
 src/ThreadModel/Models.txt -text
 src/WatchDog.php -text
 src/test.php -text
+tests/BasicTest.php -text
+tests/NewThreadTest.php -text
 tests/_support/UnitTester.php -text
 tests/unit.suite.yml -text

codeception.yml

@@ -1,13 +1,30 @@
+
+namespace: NxSys\Toolkits\Parallax
+
 suites:
     unit:
         path: .
 
 settings:
     shuffle: true
     lint: true
+    strict_xml: true
+    be_strict_about_changes_to_global_state: true
+    report_useless_tests: true
+    disallow_test_output: false
+    log_incomplete_skipped: true
+    colors: true
+
+coverage:
+    enabled: true
+    include:
+        - src/*
+    low_limit: 33
+    high_limit: 80
+    show_only_summary: false
+
 paths:
     tests: tests
     output: tests/_output
     support: tests/_support
     data: tests
-     

composer.json

@@ -11,6 +11,10 @@
     "require-dev":
     {
         "codeception/codeception": "^3.0"
+	},
+    "autoload":
+    {
+        "psr-4": { "NxSys\\Toolkits\\Parallax\\": "src" }
     },
     "license": "MIT",
     "authors":

src/Agent/BaseAgent.php

@@ -42,7 +42,7 @@
  * @throws NxSys\Toolkits\Parallax\IException Well, does it?
  * @author Chris R. Feamster <cfeamster@f2developments.com>
  */
- class BaseAgent extends Worker // implements IAgent
+ class BaseAgent implements IAgent
  {
 
  }

src/Job/BaseJob.php

@@ -33,12 +33,16 @@
 /** Library Dependencies **/
 use NxSys\Core\ExtensibleSystemClasses as CoreEsc;
 
+use parallel\Runtime as Thread_Runtime;
+use parallel\Channel as Thread_Channel;
+
 //....
 use SplQueue;
-use Thread;
-use Stackable;
 use Exception;
 use Throwable;
+use Closure;
+
+const DEFAULT_CHANNEL_CAPACITY = 1024;
 
 
 /**
@@ -50,15 +54,81 @@
  * @author Chris R. Feamster <cfeamster@f2developments.com>
  */
 // abstract class BaseJob extends CoreEsc\pthreads\Thread implements IJob
-abstract class BaseJob extends Thread implements IJob
+class BaseJob implements IJob
 {
+	const DEFAULT_CHANNEL_CAPACITY = DEFAULT_CHANNEL_CAPACITY;
+
 	protected $aLocalConstants = [];
+	public $hThreadRuntime;
 	public function __construct()
 	{
-		$this->aInData=new SplQueue ;
-		$this->aOutData=new SplQueue ;
+
+		// $this->aInData=new CoreEsc\spl\SplQueue ;
+		// $this->aOutData=new CoreEsc\spl\SplQueue ;
+		$this->aInData=new Thread_Channel(DEFAULT_CHANNEL_CAPACITY);
+		$this->aOutData=new Thread_Channel(DEFAULT_CHANNEL_CAPACITY);
+		$this->setRunMethod();
+
+	}
+
+	public function setRunMethod(string $sMethodName = 'run')
+	{
+		if (!method_exists($this, $sMethodName))
+		{
+			throw new InvalidArgumentException($sMethodName." is a not a valid method on ".__CLASS__);
+		}
+		$this->sRunMethodName=$sMethodName;
+	}
+
+	public function setRuntime(Thread_Runtime $hRuntime = null): ?Thread_Runtime
+	{
+		return $this->hThreadRuntime=$hRuntime;
+	}
+
+	public function start(int $iLegacyOptions=0, array $aThreadArguments=[])
+	{
+		if (!$this->hThreadRuntime)
+		{
+			$this->hThreadRuntime=new Thread_Runtime(__DIR__.'\..\..\vendor\autoload.php');
+		}
+		$hScopedBooter=Closure::fromcallable([$this, 'bootThread']);
+		//$hScopedBooter = $hScopedBooter->bindTo($this);
+		$this->hThreadState=$this->hThreadRuntime->run($hScopedBooter, [new $this, [$this->aInData, $this->aOutData]]);//, [($this), $aThreadArguments]);
+		return $this->hThreadState; #"Future"
+	}
+
+	public function isRunning(): bool
+	{
+		return $this->hThreadState->cancelled() || $this->hThreadState->done();
+	}
+
+	/**
+	 * @see parallel\Future::value
+	 */
+	public function resolveJobToValue()
+	{
+		return $this->hThreadState->value();
 	}
 
+	protected function bootThread($oJob, array $aThreadArguments=[]) //: mixed
+	{
+		//require_once __DIR__.'\..\..\vendor\autoload.php';
+		// $oJob = unserialize($oJob);
+		$oJob->initConstants();
+		//channel shenanigans
+		return false?:call_user_func_array([$oJob, $oJob->sRunMethodName], $aThreadArguments);
+	}
+
+	public function run()
+	{
+		$sGoal="I am!";
+		return $sGoal;
+	}
+
+	//protected abstract function run();
+
+	//---
+
 	public function setupConstants(array $aConstants): void
 	{
 		foreach ($aConstants as $name)

src/Job/IJob.php

@@ -42,7 +42,9 @@
  * @throws NxSys\Toolkits\Parallax\IException Well, does it?
  * @author Chris R. Feamster <cfeamster@f2developments.com>
  */
- interface IJob 
+ interface IJob
  {
-
+	//protected function run();
+	function start();
+	function isRunning();
  }

src/Supervisor.php

@@ -37,7 +37,7 @@
  * @throws NxSys\Toolkits\Parallax\IException Well, does it?
  * @author Chris R. Feamster <cfeamster@f2developments.com>
  */
- class Supervisor extends Pool //CoreEsc\pthreads\Pool
+ class Supervisor
  {
 
  }

tests/BasicTest.php

@@ -0,0 +1,48 @@
+<?php
+
+namespace NxSys\Toolkits\Parallax;
+
+use NxSys\Toolkits\Parallax;
+
+class BasicTest extends \Codeception\Test\Unit
+{
+
+    protected function _before()
+    {
+		codecept_debug("\n");
+		codecept_debug(sprintf(">>>CHECKPOINT %s::%s:%s<<<\n", __CLASS__, __METHOD__, __LINE__));
+		require_once __DIR__.'\..\vendor\autoload.php';
+    }
+
+    protected function _after()
+    {
+		codecept_debug(sprintf(">>>CHECKPOINT %s::%s:%s<<<\n", __CLASS__, __METHOD__, __LINE__));
+    }
+
+    // tests
+    public function testBaseJobCreation()
+    {
+		codecept_debug(sprintf(">>>CHECKPOINT %s::%s:%s<<<\n", __CLASS__, __METHOD__, __LINE__));
+		$oPlainJob=new class extends Parallax\Job\BaseJob
+		{
+			public function run()
+			{
+				$sGoal="I am!";
+				echo $sGoal;
+			}
+		};
+		$this->assertInstanceOf(Parallax\Job\BaseJob::class, $oPlainJob);
+    }
+    public function testBaseJobExecution()
+    {
+		codecept_debug(sprintf(">>>CHECKPOINT %s::%s:%s<<<\n", __CLASS__, __METHOD__, __LINE__));
+		$sGoalValue='I am!';
+
+		$oPlainJob=new Parallax\Job\BaseJob;
+		$hThreadFuture = $oPlainJob->start();
+		$sJobReturnValue=$oPlainJob->resolveJobToValue();
+
+		$this->assertEquals($sGoalValue, $sJobReturnValue);
+		$this->assertEquals($hThreadFuture->value(), $sJobReturnValue);
+    }
+}

tests/NewThreadTest.php

@@ -0,0 +1,18 @@
+<?php 
+class NewThreadTest extends \Codeception\Test\Unit
+{
+
+    protected function _before()
+    {
+    }
+
+    protected function _after()
+    {
+    }
+
+    // tests
+    public function testSomeFeature()
+    {
+
+    }
+}