Perl線程隊列和信號量概念解析
本文和大家重點學習一下Perl線程的相關知識,主要包括信號量,Perl線程隊列,其他有用的非核心包等內容,希望通過本文的學習你對Perl線程的概念有新的認識。
信號量
Thread::Semaphore包為Perl線程提供了信號量的支持。你可以創建一個自己的信號量,并通過down操作和up操作來實現對資源的同步訪問。實際上,down操作和up操作對應的就是我們所熟知的P操作和V操作。從內部實現上看,Thread::Semaphore本質上就是加了鎖的共享變量,無非是把這個加了鎖的共享變量封裝成了一個Perl線程安全的包而已。由于信號量不必與任何變量綁定,因此,它非常靈活,可以用來控制你想同步的任何數據結構和程序行為。例如
清單13.Perl線程中的信號量
- usethreads;
- usethreads::shared;
- useThread::Semaphore;
- my$s=Thread::Semaphore->new();
- $s->down();#Poperation
- ...
- $s->up();#Voperation
從本質上說,信號量是一個共享的整型變量的引用。默認情況下,它的初始值為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線程安全的隊列支持。與信號量類似,從內部實現上看,Thread::Queue也是把一個通過鎖機制實現同步訪問的共享隊列封裝成了一個Perl線程安全的包,并提供統一的使用接口。Thread::Queue在某些情況下可以大大簡化Perl線程間通信的難度和成本。例如在生產者-消費者模型中,生產者可以不斷地在Perl線程隊列上做enqueue操作,而消費者只需要不斷地在Perl線程隊列上做dequeue操作,這就很簡單地實現了生產者和消費者之間同步的問題。
例如
清單15.生產者-消費者模型中對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();
其他有用的非核心包
本文前面討論的所有內容都在Perl線程核心包的范疇之內。其實CPAN上還有其他一些與Perl線程相關的非核心包,它們往往也會給Perl線程的使用帶來很大的便利,這里我們選出兩個稍加介紹,拋磚引玉。
Thread::Pool包允許你在程序中創建一批Perl線程去完成多個類似的任務。例如當你希望創建一個多Perl線程程序去完成檢驗1000個ip地址是否都能ping通的任務時,Thread::Pool包可以給你帶來便利。
Thread::RWLock包為Perl線程中的讀寫操作提供了鎖機制的支持。例如當你有多個reader和writerPerl線程共同訪問某一個或幾個文件時,Thread::RWLock包可以給你帶來便利。
【編輯推薦】