php - ReactPHP のリスナーとタイマー?

Question

いくつかのことを行う小さなアプリケーションを構築しようとしています。

メインクラスは、ワーカーを生成、破棄、リッスン、および管理します...

<?php

  namespace Queue;

  class Controller extends Process
  {
    public $workers = array();
    function __construct()
    {
      //Run the Process constructor before doing anything else.
      parent::__construct();
    }
    function spawnWorker($businessId)
    {
      $this->workers[$businessId] = new \React\ChildProcess\Process("php index.php worker $businessId");
      $this->workers[$businessId]->start($this->loop);
      $this->workers[$businessId]->stdout->on("data", function($output) use(&$businessId)  {
        $this->channels->out->write("Child $businessId Said: " . $output);
      });
    }
    function outputToWorker($businessId, $string)
    {
      $this->workers[$businessId]->stdin->write($string);
    }
    function run()
    {
      $this->loop->run();
    }
  }

コントローラーによって管理される一連のワーカー (最終的には、データベースで定義されたキューを管理する長時間実行されるプロセスを持つことになります)...

<?php

  namespace Queue;

  class Worker extends Process
  {
    function __construct($businessId)
    {
      //Run the Process constructor before doing anything else.
      parent::__construct();
      // Assign a business to this worker.
      $this->businessId = $businessId;
      // Create a queue object for this worker.
      $this->queue = new \stdClass;
    }
    function run()
    {
      $this->channels->in->on("data", function($input) {
        $this->sendOutput($input);
      });
      $this->loop->run();
    }
  }

しかし、コードが期待どおりに動作しない状況に遭遇しました...

// Based on command line argument, decide which kind of process to spawn.
  if (!isset($argv[1]) || $argv[1] === "controller")
  {
    $controller = new Controller;
    $controller->spawnWorker(1);
    $controller->outputToWorker(1, "Before Run");
    $controller->run();
    $controller->outputToWorker(1, "After Run");
  } else if (strtolower($argv[1]) === "worker" && isset($argv[2]))
  {
    $worker = new Worker($argv[1]);
    $worker->run();
  }

この最後のコードは、アプリケーションを起動するために実際に実行するファイルです。コマンドライン引数に基づいて、どの種類のプロセスを生成するかをルーティングします。(この方法では、さまざまな種類のプロセス用のファイルを用意する必要はありません。)

ワーカーは正しく生成され、最初のメッセージ ( Child 1 Said: Before Run) がワーカーに送信されstdout、controllerワー​​カーはそれを に送信し、 はそのイベントを聞いて自身の に送信しますstdout。

ただし、リスナーは1回限りのリスナーのようで、イベントループはそれを何度も再処理していません。run()つまり、最初のオンの後はいつでも、ワーカーからのイベントcontrollerに応答しません。stdout

タイマーを使用して独自の明示的なリスナーを作成する必要がありますか?