Repeated dispatch with AnyEvent

2010年1月 8日 21:40 D | ブログ記事のURL | コメント(0) | トラックバック(0)

update: そういわれればこの例だけだったらgoto \&SUBでよかった！

例えば、AnyEvent::DBIで Q4Mを使って、＊常に＊なんらかのイベントをqueue_wait()する状態にしたいとする。するとexec()が終わったらまた同じexec()を呼ぶ事になるので、例えばこんなコードを書くかもしれない。

    use strict;
    use AnyEvent::DBI;

    my $sql = "SELECT ....  FROM queue_table WHERE queue_wait('queue_table', 10)";
    my $dispatch;
    $dispatch = sub {
         $dbh->exec( $sql, sub {
              # �~T�~A��~A��~A~M�~A~_�~@��~A��~A��~B~S�~A~K�~A~Y�~B~K
              $dispatch->();
         });
    };

    $dispatch->();

    # �~A��~A~A�~V�~A��~K�~A~W�~A��~B~K�~C~W�~C��~B��~C��~C| �~A�使�~A~F�~A| �~B~M�~A~F�~A~K�~B~I�~@~A�~\��~]��~A��~A~D�~B~I�~A��~A~D�~A~Q�~A��~C��~C��~C�
    AE::cv->recv;

でもこれだと再帰的に exec()を呼んで、さらにまた$dispatchからexecを呼んで・・・って事になってしまうよね。これを無くしたい。検証のためにもっとも単純なクロージャを使った再帰呼び出しをまず書いてみる。ここではスタックの深さをついでに表示しておく：

use strict;
 
my $dispatch; $dispatch = sub {
    my $i = 0;
    while(1) {
        my @caller = caller($i++);
        # noop
        last if ! scalar @caller;
    }
    print "$i\n";
    $dispatch->();
};

$dispatch->();

このコードを実行すると、エラーを起こすまで、少しずつ表示される数が大きくなっていく。これは再帰的に関数を呼び出し続けている数なわけで、どこかの時点でdeep recursion云々言われる。当たり前だよね。

さて、ではこれをAnyEventを使ってる場合はどうするか。まずひとつ簡単な方法としては idleウォッチャーを設定する事ができる：

use strict;
use AnyEvent;

my $idle;
my $dispatch; $dispatch = sub {
    my $i = 0;
    while(1) {
        my @caller = caller($i++);
        # noop
        last if ! scalar @caller;
    }
    print "$i\n";
    <span style="color: #f00">$idle = AE::idle $dispatch;</span>

};

<span style="color: #f00">$idle = AE::idle $dispatch;</span>

AE::cv->recv;

このコードを実行した場合、自分の環境では"6"が繰り返し表示されるだけ。idle()はイベントループが「次にビジーでない状態」に与えられた関数を実行するウォッチャーなので、続々と実行してくれるわけです。

「次にビジーでない状態」という曖昧な状態ではなく、確実にすぐ実行したい場合はタイマーを使ってもよいかも。この場合最初の引数に0を渡しておいてやれば、とにかく次の機会にすぐクロージャを実行してくれる。この場合も自分の環境では"6"が繰り返し表示される：

use strict;
use AnyEvent;

my $count = 1;
my $w;
my $dispatch; $dispatch = sub {
    my $i = 0;
    while(1) {
        my @caller = caller($i++);
        # noop
        last if ! scalar @caller;
    }
    print "$i\n";
    <span style="color: #f00">$w = AE::timer 0, 0, $dispatch;</span>
};

<span style="color: #f00">$w = AE::timer 0, 0, $dispatch;</span>

AE::cv->recv;

というわけで、直接Perlの関数を呼び出すのではなく、イベントループに一旦預ける事によって再帰的呼び出しを続けるのを減らすことができるのです。

トラックバック(0)

このブログ記事に対するトラックバックURL: http://mt.endeworks.jp/cgi-bin/mt-tb.cgi/2434

コメントする

このページは、Dが2010年1月 8日 21:40に書いたブログ記事です。

ひとつ前のブログ記事は「正月」です。

次のブログ記事は「YPUNをやりたい」です。

最近のコンテンツはインデックスページで見られます。過去に書かれたものはアーカイブのページで見られます。