1

似乎在线程中使用管道可能会导致线程变成僵尸。事实上，管道中的命令变成了僵尸，而不是线程。这种情况不会发生，这很烦人，因为很难找出真正的问题。如何处理这个问题？这些是什么原因造成的？和管道有关吗？如何避免这种情况？

以下是创建示例文件的代码。

#buildTest.pl
use strict;
use warnings;

sub generateChrs{
    my ($outfile, $num, $range)=@_;
    open OUTPUT, "|gzip>$outfile";
    my @set=('A','T','C','G');
    my $cnt=0;
    while ($cnt<$num) {
        # body...
        my $pos=int(rand($range));
        my $str = join '' => map $set[rand @set], 1 .. rand(200)+1;
        print OUTPUT "$cnt\t$pos\t$str\n";
        $cnt++
    }
    close OUTPUT;
}

sub new_chr{
    my @chrs=1..22;
    push @chrs,("X","Y","M", "Other");
    return @chrs;
}

for my $chr (&new_chr){
    generateChrs("$chr.gz",50000,100000)
}

以下代码偶尔会创建僵尸线程。原因或触发因素仍然未知。

#paralRM.pl
use strict;
use threads;
use Thread::Semaphore;
my $s = Thread::Semaphore->new(10);

sub rmDup{
    my $reads_chr=$_[0];
    print "remove duplication $reads_chr START TIME: ",`date`;
    return 0 if(!-s $reads_chr);

    my $dup_removed_file=$reads_chr . ".rm.gz";
    $s->down();
    open READCHR, "gunzip -c $reads_chr |sort -n -k2 |" or die "Error: cannot open $reads_chr";
    open OUTPUT, "|sort -k4 -n|gzip>$dup_removed_file";

    my ($last_id, $last_pos, $last_reads)=split('\t',<READCHR>);
    chomp($last_reads);
    my $last_length=length($last_reads);
    my $removalCnts=0;

    while (<READCHR>) {
        chomp;
        my @line=split('\t',$_);
        my ($id, $pos, $reads)=@line;
        my $cur_length=length($reads);
        if($last_pos==$pos){
            #may dup
            if($cur_length>$last_length){
                ($last_id, $last_pos, $last_reads)=@line;
                $last_length=$cur_length;
            }
            $removalCnts++;
            next;
        }else{
            #not dup
        }
        print OUTPUT join("\t",$last_id, $last_pos, $last_reads, $last_length, "\n");
        ($last_id, $last_pos, $last_reads)=@line;
        $last_length=$cur_length;
    }

    print OUTPUT join("\t",$last_id, $last_pos, $last_reads, $last_length, "\n");
    close OUTPUT;
    close READCHR;
    $s->up();
    print "remove duplication $reads_chr END TIME: ",`date`;
    #unlink("$reads_chr")
    return $removalCnts;
}


sub parallelRMdup{
    my @chrs=@_;
    my %jobs;
    my @removedCnts;
    my @processing;

    foreach my $chr(@chrs){
        while (${$s}<=0) {
            # body...
            sleep 10;
        }
        $jobs{$chr}=async {
            return &rmDup("$chr.gz")
            }
        push @processing, $chr;
    };

    #wait for all threads finish
    foreach my $chr(@processing){
        push @removedCnts, $jobs{$chr}->join();
    }
}

sub new_chr{
    my @chrs=1..22;
    push @chrs,("X","Y","M", "Other");
    return @chrs;
}

&parallelRMdup(&new_chr);
4

1 回答 1

0

正如您对原始帖子的评论所暗示的那样 - 您的代码没有任何明显错误。可能有助于理解的是什么是zombie过程。

具体来说 - 它是一个衍生进程（由您的open）退出，但父进程尚未收集它的返回码。

对于短时间运行的代码，这并不是那么重要 - 当你的主程序退出时，僵尸将“重新成为”，init它会自动清理它们。

对于更长时间的运行，您可以使用waitpid它们来清理它们并收集返回码。

现在在这种特定情况下-我看不到特定问题，但我想这与您打开文件句柄的方式有关。像你一样打开文件句柄的缺点是它们是全局范围的——当你做一些棘手的事情时，这通常是个坏消息。

我想如果你改变你的open电话：

my $pid = open ( my $exec_fh, "|-", "executable" );

然后在你之后调用waitpid它，然后你的僵尸就会完成。测试回报以了解您的哪些高管犯了错误（如果有的话），这应该可以帮助您找出原因。$pidclosewaitpid

或者-设置$SIG{CHLD} = "IGNORE";这将意味着您-有效地-告诉您的子进程“立即离开”-但如果它们死亡，您将无法从它们那里获得返回码。

于 2015-02-14T13:33:13.317 回答