amphp#64 some progress

lib/Worker/DefaultPool.php

@@ -252,4 +252,11 @@ private function pull(): Worker
 
         return $worker;
     }
+
+	public function restart($force = false): Promise
+	{
+
+	}
+
+
 }

lib/Worker/Internal/PooledWorker.php

@@ -72,4 +72,11 @@ public function kill()
     {
         $this->worker->kill();
     }
+
+	public function restart($force = false): Promise
+	{
+		return $this->worker->restart($force);
+	}
+
+
 }

lib/Worker/TaskWorker.php

@@ -150,4 +150,16 @@ public function kill()
 
         $this->exitStatus = new Success(0);
     }
+
+	public function restart($force = false): Promise
+	{
+		return call(function () use ($force){
+			if($force) {
+				$this->context->kill();
+			} else {
+				yield $this->shutdown();
+			}
+			yield $this->context->start();
+		});
+	}
 }

lib/Worker/Worker.php

@@ -41,4 +41,11 @@ public function shutdown(): Promise;
      * Immediately kills the context.
      */
     public function kill();
+
+	/**
+	 * Restart worker
+	 * @param bool $force Whether for cancel current task or wait it finished
+	 * @return Promise
+	 */
+	public function restart($force = false): Promise;
 }

test/Worker/AbstractWorkerTest.php

@@ -262,4 +262,32 @@ public function run(Environment $environment)
             yield $worker->shutdown();
         });
     }
+
+
+	public function testRestart()
+	{
+		Loop::run(function () {
+			$worker = $this->createWorker();
+			for($i=0; $i<=1; $i++) {
+				$returnValue = yield $worker->enqueue(new TestTask(42));
+				$this->assertEquals(42, $returnValue);
+
+				yield $worker->restart();
+			}
+		});
+	}
+
+	public function testForceRestart()
+	{
+		Loop::run(function () {
+			$worker = $this->createWorker();
+			for($i=0; $i<=1; $i++) {
+				$returnValue = yield $worker->enqueue(new TestTask(42));
+				$this->assertEquals(42, $returnValue);
+
+				yield $worker->restart(true);
+			}
+		});
+	}
+
 }