Perl AnyEvent中的watcher實例

更新時間：2014年09月17日 11:21:14 作者：鄉(xiāng)村運維

這篇文章主要介紹了Perl AnyEvent中的watcher實例,關(guān)于AnyEvent請參閱的更多介紹請參閱文中的相關(guān)鏈接,需要的朋友可以參考下

這幾天看了下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

http://www.dbjr.com.cn/article/55278.htm

1、什么是事件編程？

舉個簡單的例子，你瀏覽網(wǎng)頁的時候，你點擊一個圖片，蹭的彈出一個東西，你不點，那就在那里，等待一個人來點它。如果你寫過js，其實就是，你注冊了很多的時間比如click，dbclick，keybord，submit等，那么瀏覽器就起到幫我們?nèi)ケO(jiān)聽這些事件的發(fā)生（Loop）。當有對應的事件發(fā)生的時候，我們也一般也設(shè)置了callback，比如onclick，onsubmit等，去響應這些事件，這基本就是事件編程的一個縮影了。

2、perl AnyEvent中的watcher

在AnyEvent中有5中watcher，分別是IO，timer，signal, child, idle.

2.1 io watcher

復制代碼代碼如下:

#!/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

timer watcher

AnyEvent 的timer的一部分其實像javascript的setInterval :

復制代碼代碼如下:

#!/usr/bin/perl

use 5.016;

use AnyEvent ;

my $cv = AnyEvent->condvar ;

my $w = AnyEvent->timer(

    after => 0 ,  #多少秒之后觸發(fā)事件

    interval => 2 ,  #多少秒觸發(fā)事件

    cb => sub {

        say AnyEvent->time ," ",AnyEvent->now ;

    }

);

$cv->recv;

signal watcher

前面我們在的文章中寫到了perl中對于信號的處理《perl信號處理簡單學習》，這里主要是AnyEvent中對于這些事件的處理。

復制代碼代碼如下:

#!/usr/bin/perl

use 5.016;

use AnyEvent ;

#say for keys %SIG; 看一下又多少信號

my $cv = AnyEvent->condvar ;

my $w = AnyEvent->signal(

    signal => 'INT',

    cb => sub {

        say AnyEvent->time ," ",AnyEvent->now ;

        exit 1 ;

    }

);

$cv->recv;

child watcher

復制代碼代碼如下:

#!/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;

idle watcher

就是如果main loop在空閑的時候做些什么呢？

復制代碼代碼如下:

#!/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;