update/staging add dependency for Threading, buggy

.gitignore

@@ -10,3 +10,4 @@ vendor/
 *.csr
 *.local
 temp
+test.php

Coroutine/Coroutine.php

@@ -4,11 +4,12 @@
 
 namespace Async;
 
-use Async\Spawn\Thread;
 use Async\Spawn\Future;
 use Async\Spawn\FutureHandler;
 use Async\Spawn\FutureInterface;
 use Async\Spawn\ChanneledInterface;
+use Async\Threads\Thread;
+use Async\Threads\TWorker;
 use Async\Kernel;
 use Async\Task;
 use Async\Parallel;
@@ -488,7 +489,7 @@ public function addFuture($callable, int $timeout = 0, bool $display = false, $c
     return $display ? $future->displayOn() : $future;
   }
 
-  public function addThread(int $tid, callable $callable, ...$args): Thread
+  public function addThread(int $tid, callable $callable, ...$args): TWorker
   {
     return $this->thread->create($tid, $callable, ...$args);
   }

Coroutine/CoroutineInterface.php

@@ -8,7 +8,8 @@
 use Async\Spawn\Channeled;
 use Async\Spawn\FutureInterface;
 use Async\RuntimeException;
-use Async\Spawn\Thread;
+use Async\Threads\Thread;
+use Async\Threads\TWorker;
 
 interface CoroutineInterface
 {
@@ -304,9 +305,9 @@ public function addFuture($callable, int $timeout = 0, bool $display = false, $c
    * @param string|int $tid Thread ID
    * @param callable $callable
    * @param mixed ...$args
-   * @return Thread
+   * @return TWorker
    */
-  public function addThread(int $tid, callable $callable, ...$args): Thread;
+  public function addThread(int $tid, callable $callable, ...$args): TWorker;
 
   /**
    * There are no **UV** file system operations/events pending.

Coroutine/Kernel.php

@@ -21,7 +21,8 @@
 use Async\Misc\ContextInterface;
 use Async\Misc\Semaphore;
 use Async\Misc\TimeoutAfter;
-use Async\Spawn\Thread;
+use Async\Threads\Thread;
+use Async\Threads\TWorker;
 use Async\Spawn\Channeled;
 use Async\Spawn\FutureInterface;
 use Psr\Container\ContainerInterface;
@@ -275,7 +276,7 @@ function (TaskInterface $task, CoroutineInterface $coroutine) use ($tid, $custom
 
           $error = ($isContext || $type) ? new TaskCancelled("Task {$tid}!") : new CancelledError("Task {$tid}!");
           $customData = $cancelTask->getCustomData();
-          if ($customData instanceof FutureInterface || $customData instanceof Thread) {
+          if ($customData instanceof FutureInterface || $customData instanceof Thread || $customData instanceof TWorker) {
             $task->sendValue(true);
             $cancelTask->setCaller($task);
             if ($customData instanceof FutureInterface) {
@@ -334,7 +335,7 @@ function (TaskInterface $task, CoroutineInterface $coroutine) use ($tid) {
           }
 
           $customData = $join->getCustomData();
-          if ($customData instanceof Thread) {
+          if ($customData instanceof Thread || $customData instanceof TWorker) {
             $coroutine->schedule($join);
             return $customData->join($tid);
           }
@@ -1168,7 +1169,7 @@ function (TaskInterface $task, CoroutineInterface $coroutine) use ($callable, $t
           $callableTask = $coroutine->getTask($taskId);
           if (!$coroutine->isCompleted($taskId)) {
             $futureThread = $callableTask->getCustomData();
-            if ($futureThread instanceof FutureInterface || $futureThread instanceof Thread) {
+            if ($futureThread instanceof FutureInterface || $futureThread instanceof Thread || $futureThread instanceof TWorker) {
               $callableTask->setCaller($task);
               if ($futureThread instanceof FutureInterface) {
                 $delay = 1;

composer.json

@@ -41,7 +41,8 @@
         "php": ">7.1",
         "psr/log": "^1.0.0",
         "psr/container": ">2.0",
-        "symplely/spawn": "^4.1.8"
+        "symplely/spawn": "^5",
+        "symplely/thread_queue": "main-dev"
     },
     "autoload": {
         "files": [