AnyEventでの簡単なFIFOキューの作り方

2009年11月24日 14:01 D | ブログ記事のURL | コメント(0) | トラックバック(1)

# 追記: 2010 19 Feb - このコード何回も書くの面倒くさくなったので、

# CPANにモジュールアップロードしてしまいました

# http://search.cpan.org/dist/AnyEvent-FIFO/

まぁ考えてみれば単純な話ですけど、いわゆるGuardを使うとよいです。参考はAnyEvent::HTTP

コールバック$cbの最初の引数をguard変数にしておき、キューの１スロットを使用している間はこのguard変数をundefしないようにしておく感じです。

   use strict;
   use AnyEvent;
   use AnyEvent::Util;

   my @q; # �~_�~Z~[�~A��~B��~C��~C��~C~P�~C~C�~B��~B~R�~E��~B~L�~A��~A~J�~A~O�~A��~A~S�~B~M
   my $ACTIVE = 0; # �~O��~\��~A�使�~T�中�~B��~C��~C~C�~C~H
   my $MAX_ACTIVE = 1; # �~\~@大�~U�~@~K�~A��~B��~C��~C��~C~P�~C~C�~B��~B~R�~@~L�~P~L�~Y~B�~@~M�~A��~L�~A~F�~A~K�~H�~B~B�~A��~B~M�~B~S�~\��~S�~A��~P~L�~Y~B�~A~X�~B~C�~A��~A~D�~B~H�~A�~I

  sub drain_queue {
      while ( @q && $ACTIVE < $MAX_ACTIVE ) {
          if (my $cb = shift @q) {
              $ACTIVE++;
              $cb->( AnyEvent::Util::guard {
                  $ACTIVE--;
                  drain_queue();
              });
          }
      }
  }

デモ程度に 1から10までの数字を（最低）0.5秒あけてから表示するコード：

my $cv = AE::cv;

# XXX - 12/1: �~B~H�~A~O�~B~H�~A~O�~@~C�~A~H�~A~_�~B~I�~A~S�~A~S�~A�begin()/end()使�~A~F�~A��~A~S�~B~M�~A| �~A��~A~_�~A��~A�
# 修正�~A~W�~A��~A~J�~A~D�~A~_
for my $x (1..10) {
    $cv->begin;
    push @q, sub {
        my $guard = shift;
        my $w; $w = AE::timer 0.5, 0, sub {
            undef $guard;
            undef $w;
            warn $x;
            $cv->end;
        };
    };
}

drain_queue();

$cv->recv;