This commit is contained in:
2020-12-23 16:58:16 +08:00
parent 062b7ff769
commit 4941fa24f4
+5 -2
View File
@@ -39,8 +39,11 @@ class Kafka extends \Snowflake\Process\Process
{
$this->channelListener();
Process::signal(SIGUSR1, function () use ($process) {
var_dump($process);
go(function () use ($process) {
$sign = Coroutine::waitSignal(SIGUSR1 | SIGTERM | SIGKILL, -1);
var_dump($sign);
});
$waite = new WaitGroup();