BinaryDevelop
  1. ホーム
  2. スクリプト・コラム
  3. パール

Perl AnyEvent ウォッチャーの例

2022-02-02 06:08:30

ここ数日、PerlのイベントプログラミングフレームワークであるAnyEventについて、以下の記事を中心に見てきました。

http://search.cpan.org/~mlehmann/AnyEvent-7.05/lib/AnyEvent.pm

http://search.cpan.org/~mlehmann/AnyEvent-7.05/lib/AnyEvent/Intro.pod

https://www.jb51.net/article/55278.htm

1. イベントプログラミングとは何ですか？

簡単な例を挙げると、ウェブを閲覧しているときに、ポップアップする何かにこびりついた画像をクリックすると、その画像はクリックされずにそこにあり、誰かがクリックするのを待っている状態だ。jsを書いていると、実は、click, dbclick, keybord, submitなどの時間をたくさん登録するわけですが、これらのイベントを聞くのを助ける役割をブラウザが担っています（Loop）。また、対応するイベントが発生したら、onclick, onsubmitなどのコールバックも設定し、これらのイベントに対応するのが一般的で、基本的にはイベントプログラミングの小宇宙と言えるでしょう。

2. perlのウォッチャー AnyEvent

AnyEventには、IO、timer、signal、child、idleの5つのウォッチャーがあります。

2.1 io ウォッチャー

コピーコード コードは以下の通りです。

#! /usr/bin/perl
use AnyEvent;
my $cv = AnyEvent->condvar;
#open my $file , '<' , 'test.txt' or die "$! " ;
open F , '<' , 'test.txt' or die "$! " ;
my $io_watcher = AnyEvent->io (
      fh => *F,
      poll => 'r',
      cb => sub {
         chomp (my $input = sysread F ,my $buf ,1024); # read a line
         warn "read: $buf\n" if $input >0 ; # output what has been read
         #$cv->send if /quit/ ; # quit program if /quit/i
      },
   );
$cv->recv; # wait until user enters /quit/i

タイマーウォッチャー

anyEventのタイマーの一部は、実際にはjavascriptのsetIntervalのようなものです。

コピーコード コードは以下の通りです。

#! /usr/bin/perl
use 5.016;
use AnyEvent ;
my $cv = AnyEvent->condvar ;
my $w = AnyEvent->timer(
    after => 0 , # how many seconds after the event is triggered
    interval => 2 , # how many seconds to trigger the event
    cb => sub {
        say AnyEvent->time ," ",AnyEvent->now ;
    }
);
$cv->recv;

シグナルウォッチャー

Perlでのシグナルの扱いについては、前回の記事 Perlの信号処理の簡単な説明 ここでは、AnyEvent でのこれらのイベントの処理に焦点を当てます。

コピーコード コードは以下の通りです。

#! /usr/bin/perl
use 5.016;
use AnyEvent ;
#say for keys %SIG; see how many more signals
my $cv = AnyEvent->condvar ;
my $w = AnyEvent->signal(
    signal => 'INT',
    cb => sub {
        say AnyEvent->time ," ",AnyEvent->now ;
        exit 1 ;
   
);
$cv->recv;

チャイルドウォッチャー

コピーコード コードは以下の通りです。

#! /usr/bin/perl
use AnyEvent;
   my $done = AnyEvent->condvar;
   my $pid = fork or exit 5;
   my $w = AnyEvent->child (
      pid => $pid,
      cb => sub {
         my ($pid, $status) = @_;
         warn "pid $pid exited with status $status";
         $done->send;
      },
   );
   # do something else, then wait for process exit
   $done->recv;

アイドルウォッチャー

つまり、メインループがアイドル状態の時に何かをしてしまったら？

コピーコード コードは以下の通りです。

#! /usr/bin/perl
use AnyEvent;
   my @lines; # read data
   my $idle_w;
   $cv = AnyEvent->condvar;
   my $io_w = AnyEvent->io (fh => \*STDIN, poll => 'r', cb => sub {
      push @lines, scalar <STDIN>;
      # start an idle watcher, if not already done
      $idle_w ||= AnyEvent->idle (cb => sub {
         # handle only one line, when there are lines left
         if (my $line = shift @lines) {
            print "handled when idle: $line";
         } else {
            # otherwise disable the idle watcher again
            undef $idle_w;
         }
      });
   });
   $cv->recv;

関連

最新

おすすめ

について
/
プライバシー・ポリシー
/
お問い合わせ
© 2022 BinaryDevelop. すべての権利は、それぞれの所有者に帰属します