本文和大家重點(diǎn)學(xué)習(xí)一下Perl線程的相關(guān)知識(shí)，主要包括信號(hào)量，Perl線程隊(duì)列，其他有用的非核心包等內(nèi)容，希望通過(guò)本文的學(xué)習(xí)你對(duì)Perl線程的概念有新的認(rèn)識(shí)。

信號(hào)量

Thread::Semaphore包為Perl線程提供了信號(hào)量的支持。你可以創(chuàng)建一個(gè)自己的信號(hào)量，并通過(guò)down操作和up操作來(lái)實(shí)現(xiàn)對(duì)資源的同步訪問(wèn)。實(shí)際上，down操作和up操作對(duì)應(yīng)的就是我們所熟知的P操作和V操作。從內(nèi)部實(shí)現(xiàn)上看，Thread::Semaphore本質(zhì)上就是加了鎖的共享變量，無(wú)非是把這個(gè)加了鎖的共享變量封裝成了一個(gè)Perl線程安全的包而已。由于信號(hào)量不必與任何變量綁定，因此，它非常靈活，可以用來(lái)控制你想同步的任何數(shù)據(jù)結(jié)構(gòu)和程序行為。例如

清單13.Perl線程中的信號(hào)量
 

usethreads;  
usethreads::shared;  
useThread::Semaphore;  
 
my$s=Thread::Semaphore->new();  
$s->down();#Poperation  
...  
$s->up();#Voperation  
 

 從本質(zhì)上說(shuō)，信號(hào)量是一個(gè)共享的整型變量的引用。默認(rèn)情況下，它的初始值為1，down操作使它的值減1，up操作使它的值加1。當(dāng)然，你也可以自定義信號(hào)量初始值和每次up或down操作時(shí)信號(hào)量的變化。例如

清單14.Perl線程中的信號(hào)量
 

usethreads;  
useThread::Semaphore;  
 
my$s=Thread::Semaphore->new(5);  
printf("s=".${$s}."\n");#s=5 
$s->down(3);  
printf("s=".${$s}."\n");#s=2 
...  
$s->up(4);  
printf("s=".${$s}."\n");#s=6 
 

 Perl線程隊(duì)列

Thread::Queue包為Perl線程提供了Perl線程安全的隊(duì)列支持。與信號(hào)量類似，從內(nèi)部實(shí)現(xiàn)上看，Thread::Queue也是把一個(gè)通過(guò)鎖機(jī)制實(shí)現(xiàn)同步訪問(wèn)的共享隊(duì)列封裝成了一個(gè)Perl線程安全的包，并提供統(tǒng)一的使用接口。Thread::Queue在某些情況下可以大大簡(jiǎn)化Perl線程間通信的難度和成本。例如在生產(chǎn)者-消費(fèi)者模型中，生產(chǎn)者可以不斷地在Perl線程隊(duì)列上做enqueue操作，而消費(fèi)者只需要不斷地在Perl線程隊(duì)列上做dequeue操作，這就很簡(jiǎn)單地實(shí)現(xiàn)了生產(chǎn)者和消費(fèi)者之間同步的問(wèn)題。
例如

清單15.生產(chǎn)者-消費(fèi)者模型中對(duì)Perl線程隊(duì)列的使用
 

#!/usr/bin/perl  
#  
usethreads;  
useThread::Queue;  
my$q=Thread::Queue->new();  
 
subproduce{  
my$name=shift;  
while(1){  
my$r=int(rand(100));  
$q->enqueue($r);  
printf("$nameproduce$r\n");  
sleep(int(rand(3)));  
}  
}  
subconsume{  
my$name=shift;  
while(my$r=$q->dequeue()){  
printf("consume$r\n");  
}  
}  
 
my$producer1=threads->create(\&produce,"producer1");  
my$producer2=threads->create(\&produce,"producer2");  
my$consumer1=threads->create(\&consume,"consumer2");  
$producer1->join();  
$producer2->join();  
$consumer1->join();  
 

 其他有用的非核心包

本文前面討論的所有內(nèi)容都在Perl線程核心包的范疇之內(nèi)。其實(shí)CPAN上還有其他一些與Perl線程相關(guān)的非核心包，它們往往也會(huì)給Perl線程的使用帶來(lái)很大的便利，這里我們選出兩個(gè)稍加介紹，拋磚引玉。

Thread::Pool包允許你在程序中創(chuàng)建一批Perl線程去完成多個(gè)類似的任務(wù)。例如當(dāng)你希望創(chuàng)建一個(gè)多Perl線程程序去完成檢驗(yàn)1000個(gè)ip地址是否都能ping通的任務(wù)時(shí)，Thread::Pool包可以給你帶來(lái)便利。
Thread::RWLock包為Perl線程中的讀寫操作提供了鎖機(jī)制的支持。例如當(dāng)你有多個(gè)reader和writerPerl線程共同訪問(wèn)某一個(gè)或幾個(gè)文件時(shí)，Thread::RWLock包可以給你帶來(lái)便利。

【編輯推薦】

1. 追溯Perl線程的歷史
2. 技術(shù)分享 如何創(chuàng)建Perl線程
3. 解析四大Perl操作符用法
4. 追蹤調(diào)查 看Perl線程如何消亡
5. 學(xué)習(xí)筆記 深入剖析Perl線程的生命周期