Merge pull request #15 from HongjiangHuang/master

fix: recive ctrl+c signal kill child process
qxsch · Mar 23, 2020 · 50b1d3b · 50b1d3b
2 parents 2c0130d + ea023d4
commit 50b1d3b
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/WorkerPool.php b/src/WorkerPool.php
@@ -26,7 +26,7 @@ class WorkerPool implements \Iterator, \Countable {
 
 	/** @var array signals, that should be watched */
 	protected $signals = array(
-		SIGCHLD, SIGTERM, SIGHUP, SIGUSR1
+		SIGCHLD, SIGTERM, SIGHUP, SIGUSR1, SIGINT
 	);
 
 	/** @var bool is the pool created? (children forked) */
@@ -339,6 +339,7 @@ protected function runWorkerProcess(WorkerInterface $worker, SimpleSocket $simpl
 		while (TRUE) {
 			$output = array('pid' => getmypid());
 			try {
+				pcntl_signal_dispatch();
 				$replacements['state'] = 'free';
 				ProcessDetails::setProcessTitle($this->childProcessTitleFormat, $replacements);
 				$cmd = $simpleSocket->receive();
@@ -781,4 +782,4 @@ public function rewind() {
 	public function valid() {
 		return !empty($this->results);
 	}
-}
+}