PHPで非同期タイマーを使用する方法は？

Question

私はPHP（ウェブソケット上）でアプリを持っており、それぞれ3秒間続くいくつかのタイマーを作成する必要があります。時間がタイマーになると、私はブール変数を変更します。各タイマーはそれ自身の変数を変更します。私のプログラムはアクティブでなければならないので、私は睡眠を使うことができません。

私は反応するPHPのタイマーは非同期だと思ったが、それはsleep（）のように振舞う。ここに私のコード：

$loop = \React\EventLoop\Factory::create(); 
    $timer = $loop->addTimer(3, function() { 
     // some acts 
    }); 

    $loop->run(); 

私は非同期タイマーを作ることができますか？

Answer 1

バックグラウンドワーカーを使用できます。 Gearmanはこれらのことに最適です。

Answer 2

私はウィンドウを使用しているので、Gearmanがひどくインストールされているため、pthreadsという形で別の決定が見つかりました。私は単に新しいスレッドを作成し、sleep（3）を入れます。

Answer 3

ギアマンのようなキューイングサーバーを使用することを推奨しますが、ギアマンが遅れたジョブをサポートしているとは思われません。ギアマンプロトコルのいずれの言及もありません。http://gearman.org/protocol/私はBeanstalkdのようなものに行くだろう。

http://kr.github.io/beanstalkd/

あなたは1つの遅延でキューに仕事を置くための責任PHPプロセス、およびキューから消費するための第二のPHPのプロセスを持っています。

beanstalkの素晴らしいライブラリクライアントはpheanstalkです。 https://github.com/pda/pheanstalkを作ってください。

簡単な使用例：

プロデューサー

$pheanstalk = new Pheanstalk('127.0.0.1'); 

$delay = 3; // delay in seconds 
$pheanstalk 
    ->useTube('choose_tube_name') 
    ->put("job payload goes here\n", 
     PheanstalkInterface::DEFAULT_PRIORITY, // 1024 as standard 
     $delay, 
     PheanstalkInterface::DEFAULT_TTR // I think that after 60 seconds by default, if not deleted by consumer after reserving job, it is automatically released back onto the queue to be consumed by another consumer. 
); 

消費者

while (1) { 
    $job = $pheanstalk 
     ->watch('choose_tube_name') 
     ->ignore('default') 
     ->reserve(); 

    echo $job->getData(); 
    $pheanstalk->delete($job); 
} 

だから、本質的に、プロデューサーは3second遅れでchoose_tube_nameチューブ/キューに仕事を置きます。 3秒後に、キューで待機しているすべての消費者が消費する準備が整います。

コンシューマーは、到着すると待っています。消費者はそれを予約し、出力をエコーし​​てジョブを削除します。また、whileループで処理されるため、別のジョブが処理されるまで待機します。

拡大するためには、複数の生産と複数消費者を持つことができます。ただし、上記の例の消費者は長期的なプロセスであることを覚えておく必要があります。したがって、メモリ使用量/リークを監視し、ジョブ間でオブジェクトを共有する点で注意してください。例えばあなたがwhileループの外でクラスをインスタンス化し、それをwhileループの内部で使用/変更すると、そのプロパティは他のジョブに入り込みます。