文章详情

  • 游戏榜单
  • 软件榜单
关闭导航
热搜榜
热门下载
热门标签
php爱好者> php文档>在perl中使用信号量等待detach后的线程

在perl中使用信号量等待detach后的线程

时间:2010-09-12  来源:snowtty

在perl中使用信号量等待detach后的线程
Submitted by 云舒 on 2008, September 11, 4:34 PM. 技术

      在perl里面等待没有detach的线程好说,直接join等待退出就可以了。但是对于被detach过的,就比较麻烦一点了。因为主函数退出的时候是不管被detach了的线程是否完成的,没有完成就强制杀死,可能会导致程序工作结果不对。可是detach线程又是不可避免的,我尤其喜欢这么做,主要原因是因为我懒,不想保存一个数组,然后去挨个儿去收割,麻烦啊。况且detach掉之后,线程结束时系统自动回收资源,更是美事一桩。

      今天测试一个小程序的时候,想到既然一般使用信号量来控制并发线程数量,那么应该也可以用信号量作为事件,来等待线程结束啊。写了个脚本测试一下,确实可行。在所有线程创建完毕,主程序要退出之前,尝试获得最大线程数量个信号,无法获得的时候会阻塞,直到成功获得。这是因为一共创建了最大并发线程数个信号量,而一个线程占用一个信号量,线程退出的时候才释放。如果能够获得到原始个数,就表示所有线程都释放了,所有线程处理完毕,程序可以结束了。

#!/usr/bin/perl
use strict;
use warnings;
use threads;
use Thread::Semaphore;
 
my $max_thread = 4;
my $semaphore = new Thread::Semaphore( $max_thread );
 
sub TestFun
{
        my $num = shift;
        my $count = 1;
        while( $count <= 3 )
        {
                print "print $num $count times in thread ".threads->self()->tid()."n";
                sleep( 1 );
                $count ++;
        }
        # 线程技术,释放一个信号量
        $semaphore->up( );
}
 
sub Wait2Quit
{
        print "Waiting to quit...n";
 
        my $num = 0;
        while( $num < $max_thread )
        {
                # 尝试获取信号量,当能够获取到最大线程数个信号量时,表示所有线程都结束了
                $semaphore->down( );
                $num ++;
                print "$num thread quit.n";
        }
        print "All $max_thread thread quit.n";
}
 
for( my $index = 1; $index <= 10; $index ++)
{
        # 获取一个信号量,控制并行的线程数量
        $semaphore->down( );
        my $thread = threads->create( &TestFun, $index );
 
        # 剥离线程,不关心返回值,系统自动回收资源
        $thread->detach();
}
 
Wait2Quit( );
 
相关阅读 更多 +
排行榜 更多 +
辰域智控app

辰域智控app

系统工具 下载
网医联盟app

网医联盟app

运动健身 下载
汇丰汇选App

汇丰汇选App

金融理财 下载