AnyEvent有个地方无法理解。

墨迹哥

最近在做一个项目，被某淫推荐用AnyEvent异步解决问题。但是发现各种奇葩的无法理解的语句，其中最特殊的就是这个
AnyEvent->condvar;

   这个东西，我看了下，所有程序都是以下几个步骤。

1. my $cv = AnyEvent->condvar;
   
2. $cv->begin;
   
3. $cv->send;
   
4. $cv->recv;
   
5. $cv->end;

复制代码

这些步骤我很难理解该在哪放。。。

例如我的程序是如此：

1. #!/usr/bin/perl
   
2. use AnyEvent;
   
3. use AnyEvent::HTTP;
   
4. use AnyEvent::DBI::MySQL;
   
5. use Data::Dumper;
   
6. use MIME::Base64;
   
7. use Parallel::ForkManager;
   
8. use String::Random;
   
9. my $pm = Parallel::ForkManager->new(10);
   
10. 
    
11.         my $cocurrent=10;
    
12. 
    
13.         my $cv = AnyEvent->condvar;
    
14. 
    
15.         doit() foreach 1..$cocurrent;
    
16. 
    
17. sub doit {  
    
18.     my $word;  
    
19.           my $cv=AnyEvent->condvar;
    
20.     $cv->begin;
    
21. 
    
22.                    http_test($h->{$key}->{'url'},$h->{$key}->{'id'},$h->{$key}->{'proxy'});
    
23. 
    
24.            $cv->end;
    
25. }
    
26. 
    
27. sub http_test{
    
28.   print "进入子模块!\n";
    
29.   my ($url,$id,$proxy) = @_;
    
30.   
    
31.   print "url: $url id: $id\n";
    
32.   $cv->begin;
    
33.   http_get( $url, sub { _http( $id,@_ )  } );
    
34. 
    
35. }

复制代码

请教我该在什么地方放begin 什么地方放end，什么地方放recv？

墨迹哥

例如以下例子，直接没有输出了。。这个比较简单些。。。

1. #!/usr/bin/perl
   
2. use AnyEvent;
   
3. use AnyEvent::HTTP;
   
4. use AnyEvent::DBI::MySQL;
   
5. use Data::Dumper;
   
6. use MIME::Base64;
   
7. use Parallel::ForkManager;
   
8. use String::Random;
   
9. my $pm = Parallel::ForkManager->new(100);
   
10. 
    
11. 
    
12. my $cocurrent=10;
    
13. 
    
14. my $cv = AnyEvent->condvar;
    
15. 
    
16. http_test() foreach 1..$cocurrent;
    
17. $cv->recv;
    
18. 
    
19. sub http_test{
    
20.         $cv->begin;
    
21.         http_get( "http://www.baidu.com/", sub { print Dumper @_  } );
    
22.         $cv->end;
    
23. }
    

复制代码

laputa73

my $cv = AnyEvent->condvar;代表事件循环开始
$recv就是整个事件循环结束
$begin和$end是一对事务.
比如你要异步取100个网站
那么每个http_get之前begin,回调里面end
全都取完了$recv结束

你看看以前斑竹贴的例子,超清晰

1. #!/usr/bin/perl
   
2. 
   
3. use strict;
   
4. use warnings;
   
5. use AnyEvent;
   
6. use AnyEvent::HTTP;
   
7. 
   
8. my $cocurrent = 100;    # 并发数
   
9. my @todoList = map { "keyword" . $_ } (1 .. 1000); # 待查询的关键词
   
10. 
    
11. my $cv = AnyEvent->condvar;
    
12. 
    
13. doit() foreach 1..$cocurrent;
    
14. 
    
15. sub doit{
    
16.     my $word = shift @todoList;
    
17.     return if not defined $word;
    
18. 
    
19.     $cv->begin;
    
20.     http_get( "http://www.baidu.com/s?wd=$word", sub { done( $word, @_ ) } );
    
21. }
    
22. 
    
23. sub done {
    
24.     my ($word, $content, $hdr) = @_;
    
25. 
    
26.     $cv->end();
    
27.     print "Search: $word\tStatus: ", $hdr->{Status}, "\n";
    
28.     doit();
    
29. }
    
30. 
    
31. $cv->recv();

复制代码

laputa73

回复 2# 墨迹哥


    你这个end明显放错位置了

墨迹哥

回复 4# laputa73


    版主写的那个确实很精细。。。。当时没很细的分析，这是自己的一个毛病。

    刚才自己摸索，写了个单例DEMO就成功了，牢牢记住了。。

    PS： 你最近也很忙挖？

laputa73

回复 5# 墨迹哥


    是很忙.
    都没啥时间自己学习了.

墨迹哥

回复 6# laputa73


    我发现这个AnyEvent多进程操作总有问题，有得时候会直接挂起。不知道为啥。

    中间总会有停顿，我不太理解之前PY所说的用一个“主进程”挂起，然后去控制的原理。

    你理解不？  

    ------
   
    最近我也忙乎极点，天天加班就在倒腾这玩意。蛋疼ing~

    MCshell童鞋被我忽悠过来上班了撒。。- - # 可是他老忙架构的事情，木有时间和我一块研究。。。

    你私信你Q给我呗，有空余时间就一起折腾下。。

laputa73

anyevent是一个事件模型。不知道你有没有学过从前c语言和汇编里面的中断。
多数AE的模块是单进程的
对于单进程程序，正常情况下程序顺序执行，如果碰到阻塞，比如查询数据库，下载网页操作。
一种思路就是等待，等完成了继续，这种显然效率很低。
另一种思路是挂起阻塞的函数， 申请一个回调事件，先处理其他的函数，等慢函数执行完了，通过回调事件，重新获取执行权。这样就实现了无阻塞。
协程coro可以看作是事件模式的一个变种的封装。
因为整个程序其实还是单进程操作，所以这里的关键是在于阻塞的操作时可以被挂起，也就是说是支持事件回调的（EV,AE等）
如果你写个sleep(),那它本身会把整个线程全部阻塞，包括事件调度，就起不到并行的效果了。看起来就是整个进程挂住了。
其他的比如socket操作，文件操作，mysql操作等等，都可能有这个问题，必须换成支持事件的版本。

另外，AE有些模块不是单进程的 ，而是通过多进程实现的。

墨迹哥

回复 8# laputa73


    目前是理解了，可能操作起来还需要点时间研究下。

flw

这就是几个同步原语，要理解这个模型，理解了之后再用。