从一段 AnyEvent 代码看闭包的使用

3P主义

闭包就是带局部状态的函数，利用闭包，可以传送大量数据给函数。相对于传参方式，主要有以下两个优点：
1. 传送的数据量大。
2. 灵活，能突破参数个数的限制。

上述的优点2在回调代码中更明显，因为回调函数接受的参数都已确定了，不能再传递额外的参数。

以下用 AnyEvent::HTTP 演示闭包的使用，代码中一共有 1000 个关键词要查询，创建了 $cocurrent 个回调函数，每个回调函数都引用着外部的 @words 和 $word ，注意回调函数是怎么再次回调自身的

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

复制代码

以上代码，每一个请求返回时，会重新创建一个新请求，并发数一直控制在 $cocurrent 个，工作良好。

yinyuemi

回复 1# 3P主义


    8错，学习了～

heidern

登个记 有时间来看

ttcn_cu

回复 1# 3P主义

学习了!
    请问  
1.  
my $cb;
   
$cb = sub {
这段能定义在foreach前面么？

2.
这个代码有没有递归特性(堆栈大小限制）？还是被AE给回避了递归？

3P主义

ttcn_cu 发表于 2012-06-23 05:18
回复 1# 3P主义

学习了!

1。 必须放在 foreach  中。
2。 没有用到递归。

cdtits

学习了，一直不太清楚何为闭包？

flw

这程序可读性咋那么差呢？

写成下面这样不好吗？

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. }

复制代码

flw

记住：Don't repeat yourself

cqf820

时间和乳沟一样，挤一挤还是有的。

ding   支持

py

回复 7# flw

看到楼主这个帖子我有一个问题。

用Coro+AnyEvent::HTTP可以写出一样功能的代码，两者都是非阻塞。这样一来，Coro就是可有可无了。Coro的优势是什么？（答案见17楼）