從一段 AnyEvent 代碼看閉包的使用

3P主義

閉包就是帶局部狀態(tài)的函數(shù)，利用閉包，可以傳送大量數(shù)據(jù)給函數(shù)。相對(duì)于傳參方式，主要有以下兩個(gè)優(yōu)點(diǎn)：
1. 傳送的數(shù)據(jù)量大。
2. 靈活，能突破參數(shù)個(gè)數(shù)的限制。

上述的優(yōu)點(diǎn)2在回調(diào)代碼中更明顯，因?yàn)榛卣{(diào)函數(shù)接受的參數(shù)都已確定了，不能再傳遞額外的參數(shù)。

以下用 AnyEvent::HTTP 演示閉包的使用，代碼中一共有 1000 個(gè)關(guān)鍵詞要查詢，創(chuàng)建了 $cocurrent 個(gè)回調(diào)函數(shù)，每個(gè)回調(diào)函數(shù)都引用著外部的 @words 和 $word ，注意回調(diào)函數(shù)是怎么再次回調(diào)自身的

1. #!/usr/bin/perl
   
2. 
   
3. use strict;
   
4. use warnings;
   
5. use AnyEvent;
   
6. use AnyEvent::HTTP;
   
7. 
   
8. 
   
9. my $cocurrent = 100;    # 并發(fā)數(shù)
   
10. my @words = map { "keyword" . $_ } (1 .. 1000); # 待查詢的關(guān)鍵詞
    
11. 
    
12. my $cv = AnyEvent->condvar;
    
13. my @c = splice(@words, 0, $cocurrent);
    
14. 
    
15. foreach my $word (@c) { # 同時(shí)創(chuàng)建 $cocurrent 個(gè)請(qǐng)求
    
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();
    

復(fù)制代碼

以上代碼，每一個(gè)請(qǐng)求返回時(shí)，會(huì)重新創(chuàng)建一個(gè)新請(qǐng)求，并發(fā)數(shù)一直控制在 $cocurrent 個(gè)，工作良好。

yinyuemi

回復(fù) 1# 3P主義


    8錯(cuò)，學(xué)習(xí)了～

heidern

登個(gè)記 有時(shí)間來(lái)看

ttcn_cu

回復(fù) 1# 3P主義

學(xué)習(xí)了!
    請(qǐng)問(wèn)  
1.  
my $cb;
   
$cb = sub {
這段能定義在foreach前面么？

2.
這個(gè)代碼有沒(méi)有遞歸特性(堆棧大小限制）？還是被AE給回避了遞歸？

3P主義

ttcn_cu 發(fā)表于 2012-06-23 05:18
回復(fù) 1# 3P主義

學(xué)習(xí)了!

1。 必須放在 foreach  中。
2。 沒(méi)有用到遞歸。

cdtits

學(xué)習(xí)了，一直不太清楚何為閉包？

flw

這程序可讀性咋那么差呢？

寫成下面這樣不好嗎？

1. #!/usr/bin/perl
   
2. 
   
3. use strict;
   
4. use warnings;
   
5. use AnyEvent;
   
6. use AnyEvent::HTTP;
   
7. 
   
8. my $cocurrent = 100;    # 并發(fā)數(shù)
   
9. my @todoList = map { "keyword" . $_ } (1 .. 1000); # 待查詢的關(guān)鍵詞
   
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. }

復(fù)制代碼

flw

記�。篋on't repeat yourself

cqf820

時(shí)間和乳溝一樣，擠一擠還是有的。

ding   支持

py

回復(fù) 7# flw

看到樓主這個(gè)帖子我有一個(gè)問(wèn)題。

用Coro+AnyEvent::HTTP可以寫出一樣功能的代碼，兩者都是非阻塞。這樣一來(lái)，Coro就是可有可無(wú)了。Coro的優(yōu)勢(shì)是什么？（答案見(jiàn)17樓）