イベントvar watcherに相当するAnyEvent？

Question

私はEvent varウォッチャーを使用して内部キューを実装しています。プロデューサスレッドが何かをキュー（配列のみ）に追加すると、監視対象変数の値が変更され、要素が追加されたことを知らせます。

AnyEventでどうすればいいですか？可変視聴をサポートしていないようです。パイプを使用してIOウォッチャーを使用する必要がありますか（つまり、プロデューサは要素を追加したときにパイプの一端にバイトを書き込みます）

Coroでこれを行う方法を知りたいと思います。

Answer 1

は、私が使用するパラダイムを考え出し：

my @queue; 
my $queue_watcher; 

sub add_item { 
    push(@queue, $_[0]); 
    $queue_watcher ||= AnyEvent->timer(after => 0, cb => \&process_queue); 
} 

sub process_queue { 
    ... # remove zero or more elements from @queue 
    if (@queue) { 
    $queue_watcher = AnyEvent->timer(after => 0, cb => \&process_queue); 
    } else { 
    undef $queue_watcher; 
    } 
} 

と場合にのみ@queueが空でない場合は基本的に$queue_watcherが定義され、アクティブにされています。

Answer 2

消費者にコントロールを戻す手段として可変視聴を使用しているかのように聞こえます。 AnyEventでは、プロデューサから$ cv-> send（）を呼び出し、コンシューマで$ cv-> recv（）を呼び出すことで、これを条件変数で行うことができます。それ以外の場合はキューに入れたい項目をsend（）することも考えられますが、パラメータなしでsendを呼び出すことは、消費者に通知するための許可された方法です。