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

Perl_Er

没错。如果退出这个循环后，你的脚本就结束了，那么最后的 wait_for_a_kid 是没有必要的。BTW，如果wait_for_a_kid 会 wait 所有已经结束的进程，那么它的名字就起的很不合适。

恩，脚本没有在循环后结束，而下面还有事情要做。所以就的wait没有被wait的进程。名字给个wait_for_all_kids好啦。最重要的是完成了其功能。

另外，再帮忙看看上面那个多线程的。谢谢！

Perl_Er

帮忙看看那个多线程的为什么会run 'out of memory'

MMMIX

原帖由 Perl_Er 于 2009-6-30 22:28 发表
测试了一下，运行这个简单的程序会"out  of memory"
#!/usr/bin/perl
use threads;
use strict;

sub prt(){
        print "hello\n";
}


my %thread_hash = ();
my $current_thread = 0;
for(0..10000)
{
         if( $current_thread >= 10 )
         {
                 foreach my $thread(keys %thread_hash )
                 {
                        if($thread->done())

你这个 done 是哪来的？我查了 Perl 5.8.8, 和 Perl 5.10.0 的文档，都没有这个函数。

Perl_Er

原帖由 MMMIX 于 2009-7-1 11:58 发表

你这个 done 是哪来的？我查了 Perl 5.8.8, 和 Perl 5.10.0 的文档，都没有这个函数。

请看这里：
http://perldoc.perl.org/Thread.html

MMMIX

原帖由 Perl_Er 于 2009-7-1 14:23 发表



请看这里：
http://perldoc.perl.org/Thread.html

Thread 和 threads 是两套不同的线程实现，现在已经不鼓励用 Thread 了。更为离奇的是，你使用了 use threads; 但却在其中用 Thread 中的函数。

Perl_Er

看来是我是混淆了这两个模块,经过修改后是这样,但是还是run out of memory.
#!/usr/bin/perl
use threads;
use strict;

sub prt(){
        print "hello\n";
}


my %thread_hash = ();
my $current_thread = 0;
for(0..2000)
{
         if( $current_thread >= 10 )
         {
                 foreach my $thread(keys %thread_hash )
                 {
                        if($thread->is_joinable())
                                {
                                        $thread->join( );
                                        delete $thread_hash{$thread};
                                }else{
                                        next;
                                }
                 }
         }else{
                $thread_hash{$_} = threads->create(\&prt);
        }
}

MMMIX

原帖由 Perl_Er 于 2009-7-1 14:50 发表
看来是我是混淆了这两个模块,经过修改后是这样,但是还是run out of memory.
my %thread_hash = ();
my $current_thread = 0;
for(0..2000)
{
         if( $current_thread >= 10 )
         {
                 foreach my $thread(keys %thread_hash )
                 {
                        if($thread->is_joinable())
                                {
                                        $thread->join( );
                                        delete $thread_hash{$thread};
                                }else{
                                        next;
                                }
                 }
         }else{
                $thread_hash{$_} = threads->create(\&prt);
        }
}

你有仔细想过这段代码的逻辑么？例如说 %thread_hash 的 key 是 thread object 么？$current_thread 会增加么？

Perl_Er

先来个简单的，这个也一样.  out of memory
#!/usr/bin/perl
use threads;
use strict;

sub prt(){
        print "hello\n";
}


my $current_thread;
my @thrs;
for(0..2000)
{
        push @thrs,threads->create(\&prt);
}


foreach(@thrs){
        $_->join();
}

Perl_Er

改成这个样子是可以的，每次起10个thread，但是每次都要等这10个完成才能起下一轮的10个，有没有更好的办法了。另外如果每次起得太多，对performance影响会比较大,如何确定同时起多少个比较合适. 谢谢！
#!/usr/bin/perl
use threads;
use strict;
use Data:umper;

sub prt(){
        `echo "hello" >> t.txt`;
}


my $current_thread;
my %thrs = ();
for(1..3000)
{
         $current_thread = scalar (keys %thrs);
         if( $current_thread < 10 )
         {
                $thrs{$_} = threads->create(\&prt);
         }else{
                print "more than 10 threads\n";
                print Dumper \%thrs;
                foreach my $t (keys %thrs){
                                $thrs{$t}->join();
                                delete $thrs{$t};
                }
                $thrs{$_} = threads->create(\&prt);
         }
}
foreach my $t (keys %thrs){
        $thrs{$t}->join();
        delete $thrs{$t};
}

print Dumper \%thrs;

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