Coro如何动态的创建新协程？

py

1. 用Coro::Semaphore控制HTTP并发。
2. 用async_pool控制创建Coro的的数量。async+join的方式是不可能控制这个的。
3. "如何在网络阻塞的时候少创建点并发，在网络状况比较流畅的时候多创点并发"，这是个主观的判断，你需要自己设置阀值，再调整并发。
4. 10楼的帖子，你看看“cede”都写到哪去了...
5. 主贴对$coro->ready的理解不正确。是不是让出CPU资源一个是通过程序做，阻塞了，Coro会主动让出CPU。另一个是手工做，通过cede。$coro->ready说的是另外一回事（详见文档）

楼主需要再多看几遍作者文档，一直问问题就一直有问题

yvmu

py 发表于 2013-08-05 10:15
1. 用Coro::Semaphore控制HTTP并发。
2. 用async_pool控制创建Coro的的数量。async+join的方式是不可能控制这个的。

谢谢斑竹，这应该是可行的，再在去看看async_pool的说明，刚接触多线程/协程，有些原理得多琢磨琢磨。

py 发表于 2013-08-05 10:15
3. "如何在网络阻塞的时候少创建点并发，在网络状况比较流畅的时候多创点并发"，这是个主观的判断，你需要自己设置阀值，再调整并发。

这个可能真的只能手动调整了。

py 发表于 2013-08-05 10:15
4. 10楼的帖子，你看看“cede”都写到哪去了...
5. 主贴对$coro->ready的理解不正确。是不是让出CPU资源一个是通过程序做，阻塞了，Coro会主动让出CPU。另一个是手工做，通过cede。$coro->ready说的是另外一回事（详见文档）

楼主需要再多看几遍作者文档，一直问问题就一直有问题

确实两个例子里面的代码都有问题，我当时是在一台Windows的机子上随手写的，也没测试，后来发现就没改，忘记了回帖说明一下。Sorry~

文档我看了几边的，但里面有些东西还是琢磨不透……

yvmu

1. #!/usr/bin/perl
   
2. 
   
3. use strict;
   
4. use warnings;
   
5. use Smart::Comments;
   
6. use Coro;
   
7. use AnyEvent::HTTP;
   
8. use Benchmark;
   
9. 
   
10. my $T0=Benchmark->new;
    
11. 
    
12. $Coro::POOL_SIZE = 2;
    
13. my $count = 1000;
    
14. my $limit = Coro::Semaphore->new( $Coro::POOL_SIZE );
    
15. my $sem = Coro::Semaphore->new( 1 - $count);
    
16. for( 1 .. $count ){
    
17.         $limit->down;
    
18.         async_pool {
    
19.                     print "$_[0] start...\n";
    
20.                 http_get 'http://www.baidu.com', cb => Coro::rouse_cb;
    
21.                 my @res = Coro::rouse_wait;
    
22.                 print $_[0]."done! $res[1]->{Status}\n";
    
23. 
    
24.             $sem->up;
    
25.             $limit->up; } $_;
    
26. };
    
27. $sem->down;
    
28. 
    
29. my $T1=Benchmark->new;
    
30. my $td = Benchmark::timediff($T1, $T0);
    
31. print Benchmark::timestr($td)."\n";
    

复制代码

这种模式好理解，就不知道斑竹是否还有更高效的代码？

yvmu

还有我这里$Coro:OOL_SIZE = 2;并发两个HTTP请求速度会最快，这个怎么理解呢？虽然不是并发越多越好，但这个并发数远远低于我的预估呀。

py

“并发多少个http请求会最快”，这个和你本地到对方URL的带宽有关系，也和对方服务器设置有关系（例如设置了每个IP10个连接）。和你用的程序语言以及机制没关系（因为你已经不是单线程连接了）。

我个人认为，Coro的存在并不是为了“最快”，拿http举例，如果你访问一个页面需要2秒，你有10个这样的页面需要访问，这个时候最快也需要2秒才能完成这10个页面。再高效也不可能突破2秒
Coro的存在是为了充分利用资源（内存，CPU，网络）完成任务，并且保证使用的资源更少。这是通过让“线程”之间有最大限度的协作来完成的。

另外，POOL_SIZE不是“控制并发数”的，它是线程池的大小。这个文档里也有说明。

yvmu

非常感谢您的指教。请问您有上irc或则google group吗？

py

没有
不过我还是经常来这个论坛的。我对Coro的理解也没有很深入，也就是“熟练使用”而已。