Perl脚本多线程不并行运行

在开始使用信号量之前,您需要了解信号量实际上是什么。你已经明确地告诉了线程 不 并行运行:

my $s           = Thread::Semaphore->new;
#...

    while ($queue_id_list->pending > 0) { 
        $s->down;
        my $info = $queue_id_list->dequeue_nb;
        if (defined($info)) {
            my @details = split(/#/, $info);
            #my $result = system("./match_name db=user_".$details[0]." id=".$details[1]); 
            # normally the script above would be launched which is a php script run in php-cli and does some database things

            sleep(0.1);

            #print "Thread: ". threads->self->tid. " - Done user: ".$details[0]. " and addressbook id: ". $details[1]."\r\n";
            #print $queue_id_list->pending."\r\n";
        }
        $s->up;
    }

你已经创建了一个信号量 $s ,默认计数为1。然后在你试图运行的函数中,你调用 $s->down 在开始时--将计数减少1,如果计数已经是<1,则为块,并且 $s->up 最后,它将计数增加1。

线程调用一次 down ,在调用之前不会运行其他线程 up 再一次。

你应该仔细阅读 the Thread::Semaphore docs ,而且可能 this wikipedia article on semaphores 也是。