关于perl的多线程&多进程的问题

Perl_Er

但是加锁的话要等待这个&prt完了才可以做下一个，那就失去了多线程的意义啦. 还是相当于一个一个执行

1. sub prt(){
   
2.     lock($thread_count);
   
3.     $thread_count++;
   
4.     print "the thread is $_[0]\n";
   
5.     sleep 5;
   
6. #    print "the count is :$thread_count","\n";
   
7.     $thread_count--;
   
8. }

复制代码

[ 本帖最后由 Perl_Er 于 2009-7-1 21:33 编辑 ]

MMMIX

原帖由 Perl_Er 于 2009-7-1 21:31 发表
但是加锁的话要等待这个&prt完了才可以做下一个，那就失去了多线程的意义啦. 还是相当于一个一个执行

你难道没有看到我上面的例子么？在线程函数中，只需要在退出的时候才需要对 $thread_num 加锁并将其减一。

Perl_Er

有时候是100个，有时候是101,100个左右是吗？

[ 本帖最后由 Perl_Er 于 2009-7-1 21:38 编辑 ]

MMMIX

原帖由 Perl_Er 于 2009-7-1 21:37 发表
有时候是100个，有时候是101,100个左右是吗？

还有 99 个，98 个，等等。

Perl_Er

我在你那个上面加了一个sleep 2，每起个新的进程要等2秒,

1. #!/usr/bin/perl
   
2. use strict;
   
3. use warnings;
   
4. 
   
5. use threads;
   
6. use threads::shared;
   
7. 
   
8. my $thread_num :shared = 0;
   
9. 
   
10. sub start_thread {
    
11.         print "Thread ", threads->tid(), " started, current thread numbers $_[0]\n";
    
12.         {
    
13.                 lock($thread_num);
    
14.                 $thread_num--;
    
15.                 sleep 2;
    
16.                 cond_signal($thread_num);
    
17.         }
    
18. }
    
19. 
    
20. for (1 .. 200) {
    
21.         {
    
22.                 lock($thread_num);
    
23.                 cond_wait($thread_num) until $thread_num < 10;
    
24. 
    
25.                 my $t = threads->create(\&start_thread, $thread_num + 1);
    
26.                 $t->detach();
    
27.                
    
28.                 $thread_num++;
    
29.         }
    
30. }

复制代码

[ 本帖最后由 Perl_Er 于 2009-7-1 21:49 编辑 ]

MMMIX

原帖由 Perl_Er 于 2009-7-1 21:48 发表
我在你那个上面加了一个sleep 2，每起个新的进程要等2秒,

干嘛要这么做？

MMMIX

更简洁的例子，使用 Thread::Semaphore

1. 
   
2. #!/usr/bin/perl
   
3. use strict;
   
4. use warnings;
   
5. 
   
6. use threads;
   
7. use Thread::Semaphore;
   
8. 
   
9. my $thread_num = Thread::Semaphore->new(10);
   
10. 
    
11. sub start_thread {
    
12.         print "Thread ", threads->tid(), " started\n";
    
13.         $thread_num->up();
    
14. }
    
15. 
    
16. for (1 .. 200) {
    
17.         $thread_num->down();
    
18.         if (my $t = threads->create(\&start_thread)) {
    
19.                 $t->detach();
    
20.         }
    
21. }
    

复制代码

同样，这个也不能保证一定会创建 200 个线程，很奇怪。

MMMIX

原帖由 MMMIX 于 2009-7-1 23:33 发表
更简洁的例子，使用 Thread::Semaphore

同样，这个也不能保证一定会创建 200 个线程，很奇怪。

在脚本的最后加上 sleep(2); 后，每次都能看到 200 个输出。看来是由于主线程提前结束，某些线程还没来得及打印信息就被结束掉了。使用 threads::shared 的实现也是类似的问题。

hitsubunnu

写了个多进程的  
xp 下开50个进程  timeout为5  局域网内ping 254个地址 用时 28秒左右

1. 
   
2. #!perl
   
3. use strict;
   
4. use warnings;
   
5. use Smart::Comments;
   
6. 
   
7. use Net::Ping::External qw(ping);
   
8. use Parallel::ForkManager;
   
9. 
   
10. my $MAX = 50;
    
11. my $pm = new Parallel::ForkManager($MAX);
    
12. 
    
13. my @hosts = map{"192.168.1.$_"}(1..254);
    
14. 
    
15. ### [<now>] start
    
16. 
    
17. foreach (@hosts) { ### Working [ % ] done
    
18.         $pm->start and next;
    
19.         my $alive = ping(hostname => $_, timeout => 5);
    
20.         print "$_ is alive!\n" if $alive;
    
21.         $pm->finish;
    
22. }
    
23. 
    
24. ### [<now>] end
    

复制代码

btw：如果perl不能满足，可以考虑改用erlang试试  随随便便一台机器就可以开几万个进程

[ 本帖最后由 hitsubunnu 于 2009-7-2 00:21 编辑 ]

Perl_Er

我在production环境中，所以只能用标准模块。