cb => $cb, # cb 是 callback 的简写,所以知道了吧,只要到了前面的条件,就会运行 cb => 指向的函数.
);
使用实例:
下面的例子是,5 秒后,每 2 秒进行一次 callback 中的事件,直到 $w 这个注册的事件被 undef 为止(也就是 $count > 10 次).这个中的 undef $w 是取消掉这种 watcher 的方法.
#!/usr/bin/perl
use strict;
use AnyEvent;
my $cv = AnyEvent->condvar;
my $count = 0;
my $w; $w = AnyEvent->timer(
after => 5,
interval => 2,
cb => sub {
$count++;
warn "这是第 $count 次调用";
if ($count >= 10) {
undef $w;
}
}
);
$cv->recv;
I/O WATCHERS
基本语法
my $fh = ....; # 打开一个句柄
my $io; $io = AnyEvent->io(
fh => $fh, # 上面打开的句柄,也可以是标准输入和输出
poll => "w", # 这个地方可以选择 r 和 w 来表示读和写的 IO 事件
cb => sub {
syswrite( $fh, "写入的内容" );
undef $io;
}
);
使用实例:
下面的例子,是使用 io 监控到可以读,就调用 cb 的函数,直接读文件 test.txt,每次一个字节,直到读完这个文件就通过 undef 消掉这个事件.
#!/usr/bin/perl
use strict;
use AnyEvent;
my $cv = AnyEvent->condvar;
open my $fh, "<test.txt" or die "不能打开文件句柄 $!";
my $io; $io = AnyEvent->io(
fh => $fh,
poll => "r",
cb => sub {
my $len = sysread( $fh, my $buf, 1 );
if ($len > 0) {
print "read '$buf'n";
}
else {
undef $io;
die "读出错: $!";
}
});
$cv->recv;
IDLE WATCHERS
基本语法
my $w = AnyEvent->idle (cb => sub { ... });
使用实例:
下面的例子,当整个程序中,没有其它事件在运行时,就会运行 idle .它就是当其它事件都在等待和空着的时候,所调用的.
#!/usr/bin/perl
use strict;
use AnyEvent;
my $cv = AnyEvent->condvar;
my $t; $t = AnyEvent->timer(
after => 1,
interval => 1,
cb => sub { print time()."n" }
);
my $w; $w = AnyEvent->idle(
cb => sub {
warn "idle";
# undef $w;
}
);
$cv->recv;
SIGNAL WATCHERS
基本语法如下,就是当接收到 POSIX signal 的时候,运行 callback 中的事件.
my $w = AnyEvent->signal (signal => "TERM", cb => sub { ... });
CHILD PROCRSS WATCHERS
基本语法如下
# child process exit
my $w = AnyEvent->child (pid => $pid, cb => sub {
