建站
咨詢
售后
建站咨詢
新聞中心
本文和大家重點學習一下Perl線程的相關(guān)知識，主要包括信號量，Perl線程隊列，其他有用的非核心包等內(nèi)容，希望通過本文的學習你對Perl線程的概念有新的認識。
信號量
Thread::Semaphore包為Perl線程提供了信號量的支持。你可以創(chuàng)建一個自己的信號量，并通過down操作和up操作來實現(xiàn)對資源的同步訪問。實際上，down操作和up操作對應(yīng)的就是我們所熟知的P操作和V操作。從內(nèi)部實現(xiàn)上看，Thread::Semaphore本質(zhì)上就是加了鎖的共享變量，無非是把這個加了鎖的共享變量封裝成了一個Perl線程安全的包而已。由于信號量不必與任何變量綁定，因此，它非常靈活，可以用來控制你想同步的任何數(shù)據(jù)結(jié)構(gòu)和程序行為。例如
清單13.Perl線程中的信號量
- usethreads;
- usethreads::shared;
- useThread::Semaphore;
- my$s=Thread::Semaphore->new();
- $s->down();#Poperation
- ...
- $s->up();#Voperation
從本質(zhì)上說，信號量是一個共享的整型變量的引用。默認情況下，它的初始值為1，down操作使它的值減1，up操作使它的值加1。當然，你也可以自定義信號量初始值和每次up或down操作時信號量的變化。例如
清單14.Perl線程中的信號量
- 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線程隊列
Thread::Queue包為Perl線程提供了Perl線程安全的隊列支持。與信號量類似，從內(nèi)部實現(xiàn)上看，Thread::Queue也是把一個通過鎖機制實現(xiàn)同步訪問的共享隊列封裝成了一個Perl線程安全的包，并提供統(tǒng)一的使用接口。Thread::Queue在某些情況下可以大大簡化Perl線程間通信的難度和成本。例如在生產(chǎn)者-消費者模型中，生產(chǎn)者可以不斷地在Perl線程隊列上做enqueue操作，而消費者只需要不斷地在Perl線程隊列上做dequeue操作，這就很簡單地實現(xiàn)了生產(chǎn)者和消費者之間同步的問題。
例如
清單15.生產(chǎn)者-消費者模型中對Perl線程隊列的使用
- #!/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)。其實CPAN上還有其他一些與Perl線程相關(guān)的非核心包，它們往往也會給Perl線程的使用帶來很大的便利，這里我們選出兩個稍加介紹，拋磚引玉。
Thread::Pool包允許你在程序中創(chuàng)建一批Perl線程去完成多個類似的任務(wù)。例如當你希望創(chuàng)建一個多Perl線程程序去完成檢驗1000個ip地址是否都能ping通的任務(wù)時，Thread::Pool包可以給你帶來便利。
Thread::RWLock包為Perl線程中的讀寫操作提供了鎖機制的支持。例如當你有多個reader和writerPerl線程共同訪問某一個或幾個文件時，Thread::RWLock包可以給你帶來便利。
當前題目：Perl線程隊列和信號量概念解析
路徑分享：http://www.dlmjj.cn/article/dphssop.html
