Perl線程生命周期的示例分析

小編給大家分享一下Perl線程生命周期的示例分析，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！

共享與同步

threads::shared

和現(xiàn)有大多數(shù)Perl線程模型不同，在PerlithreadsPerl線程模型中，默認(rèn)情況下任何數(shù)據(jù)結(jié)構(gòu)都不是共享的。當(dāng)一個(gè)新Perl線程被創(chuàng)建以后，它就已經(jīng)包含了當(dāng)前所有數(shù)據(jù)結(jié)構(gòu)的一份私有拷貝，新建Perl線程中對(duì)這份拷貝的數(shù)據(jù)結(jié)構(gòu)的任何操作都不會(huì)在其他Perl線程中有效。因此，如果需要使用任何共享的數(shù)據(jù)，都必須顯式地申明。threads::shared包可以用來實(shí)現(xiàn)Perl線程間共享數(shù)據(jù)的目的。

鎖

多Perl線程間既然有了共享的數(shù)據(jù)，那么就必須對(duì)共享數(shù)據(jù)進(jìn)行小心地訪問，否則，沖突在所難免。PerlithreadsPerl線程模型中內(nèi)置的lock方法實(shí)現(xiàn)了Perl線程間共享數(shù)據(jù)的鎖機(jī)制。有趣的是，并不存在一個(gè)unlock方法用來顯式地解鎖，鎖的生命周期以代碼塊為單位，也就是說，當(dāng)lock操作所在的代碼塊執(zhí)行結(jié)束之后，也就是鎖被隱式釋放之時(shí)。例如

清單10.Perl線程中的鎖機(jī)制    

usethreads::shared;   #inthread1  {  lock($share);#lockfor3seconds  sleep(3);#otherthreadscannotlockagain  }  #unlockimplicitlynowaftertheblock   #inthread2  {  lock($share);#willbeblocked,asalreadylockedbythread1  $share++;#afterthread1quitfromtheblock  }  #unlockimplicitlynowaftertheblock

上面的示例中，我們?cè)趖hread1中使用lock方法鎖住了一個(gè)普通的標(biāo)量，這會(huì)導(dǎo)致thread2在試圖獲取$share變量的鎖時(shí)被阻塞，當(dāng)thread1從調(diào)用lock的代碼塊中退出時(shí)，鎖被隱式地釋放，從而thread2阻塞結(jié)束，lock成功以后，thread2才可以執(zhí)行$share++的操作。對(duì)于數(shù)組和哈希表來說，lock必須用在整個(gè)數(shù)據(jù)結(jié)構(gòu)上，而不是用在數(shù)組或哈希表的某一個(gè)元素上。

假如一個(gè)Perl線程對(duì)某一個(gè)共享變量實(shí)施了鎖操作，在它沒有釋放鎖之前，如果另外一個(gè)Perl線程也對(duì)這個(gè)共享變量實(shí)施鎖操作，那么這個(gè)Perl線程就會(huì)被阻塞，阻塞不會(huì)被自動(dòng)中止而是直到前一個(gè)Perl線程將鎖釋放為止。這樣的模式就帶來了我們常見的死鎖問題。

例如
清單12.Perl線程中的死鎖    

usethreads;  usethreads::shared;  #inthread1  {  lock($a);#lockfor3seconds  sleep(3);#otherthreadscannotlockagain  lock($b);#deadlockhere  }   #inthread2  {  lock($b);#willbeblocked,asalreadylockedbythread1  sleep(3);#afterthread1quitfromtheblock  lock($a);#deadlockhere  }

死鎖常常是多Perl線程程序中最隱蔽的問題，往往難以發(fā)現(xiàn)與調(diào)試，也增加了排查問題的難度。為了避免在程序中死鎖的問題，在程序中我們應(yīng)該盡量避免同時(shí)獲取多個(gè)共享變量的鎖，如果無法避免，那么一是要盡量使用相同的順序來獲取多個(gè)共享變量的鎖，另外也要盡可能地細(xì)化上鎖的粒度，減少上鎖的時(shí)間。

信號(hào)量

Thread::Semaphore包為Perl線程提供了信號(hào)量的支持。你可以創(chuàng)建一個(gè)自己的信號(hào)量，并通過down操作和up操作來實(shí)現(xiàn)對(duì)資源的同步訪問。實(shí)際上，down操作和up操作對(duì)應(yīng)的就是我們所熟知的P操作和V操作。從內(nèi)部實(shí)現(xiàn)上看，Thread::Semaphore本質(zhì)上就是加了鎖的共享變量，無非是把這個(gè)加了鎖的共享變量封裝成了一個(gè)Perl線程安全的包而已。由于信號(hào)量不必與任何變量綁定，因此，它非常靈活，可以用來控制你想同步的任何數(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ì)上說，信號(hào)量是一個(gè)共享的整型變量的引用。默認(rèn)情況下，它的初始值為1，down操作使它的值減1，up操作使它的值加1。當(dāng)然，你也可以自定義信號(hào)量初始值和每次up或down操作時(shí)信號(hào)量的變化。

Perl線程隊(duì)列

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

其他有用的非核心包

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

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

看完了這篇文章，相信你對(duì)“Perl線程生命周期的示例分析”有了一定的了解，如果想了解更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！