如何進(jìn)行Ruby線程相關(guān)知識(shí)點(diǎn)分析

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)?lái)有關(guān)如何進(jìn)行Ruby線程相關(guān)知識(shí)點(diǎn)分析，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

Ruby語(yǔ)言一款完全面向?qū)ο蟮慕忉屝湍_本語(yǔ)言。對(duì)于這樣的一款新型編程語(yǔ)言，其特性對(duì)于程序員的吸引力不小。

今天看了Ruby線程部分。《Programming Ruby》***版的HTML版的線程和進(jìn)程部分講得很詳細(xì)?？赐旰蟾杏X就好像又把操作系統(tǒng)的這一部分重溫了一遍。尤其是Spawning New Processes那一節(jié)，如果沒有學(xué)過(guò)操作系統(tǒng)還真不知道他說(shuō)什么。

IO.popen，其中的popen，我理解應(yīng)該是應(yīng)該是"piped open"的意思。其中這段Ruby線程代碼，

1. pipe = IO.popen("-","w+")  

2. if pipe  

3. pipe.puts "Get a job!"  

4. $stderr.puts "Child says
    '#{pipe.gets.chomp}'"  

5. else  

6. $stderr.puts "Dad says 
   '#{gets.chomp}'"  

7. puts "OK"  

8. end 

簡(jiǎn)直和Unix課里面的fork代碼示例一樣，父子進(jìn)程共享同一段代碼?！禤rogramming Ruby》對(duì)這段代碼的解釋是“There's one more twist to popen. If the command you pass it is a single minus sign (``--''), popen will fork a new Ruby interpreter. Both this and the original interpreter will continue running by returning from the popen. The original process will receive an IO object back, while the child will receive nil. ”。

***次看我完全沒看出來(lái)他說(shuō)的是什么?？戳舜a后一時(shí)間也沒往fork去想。結(jié)果過(guò)了十分鐘后靈光一現(xiàn)才知道是怎么回事。同志們，看英文的東西不容易啊！

Ruby線程還挺好學(xué)。Ruby線程的功能是自已實(shí)現(xiàn)的。與操作系統(tǒng)無(wú)關(guān)。為了達(dá)到平臺(tái)無(wú)關(guān)性，這種犧牲我覺得有點(diǎn)大。不說(shuō)作者開發(fā)時(shí)得費(fèi)多少力氣。就是使用起來(lái)，也沒有本地線程的種種優(yōu)勢(shì)。比如說(shuō)線程饑餓。下面我寫了一個(gè)練習(xí)性質(zhì)的生產(chǎn)者--消費(fèi)者例子。實(shí)話說(shuō)，比Ruby中thread.rb里的例子要長(zhǎng)太多……好處是，這里解決了屏幕輸出時(shí)的竄行問題。

require 'thread'  
class Consumer  
def initialize(queue, 
stdout_mutex)  
@queuequeue = queue  
@stdout_mutexstdout_mutex 
= stdout_mutex  
end  
def consume  
product = @queue.pop  
@stdout_mutex.synchronize {  
puts "Product #{product} 
consumed."  
$stdout.flush  
}  
end  
end  
class Producer  
def initialize(queue, stdout_mutex)  
@queuequeue = queue  
end  
def produce  
product = rand(10)  
@queue.push(product)  
@stdout_mutex.synchronize {  
puts "Product #{product} produced."  
$stdout.flush  
}  
end  
end  
sized_queue = SizedQueue.new(10)  
stdout_mutex = Mutex.new  
consumer_threads = []  
100.times {  
consumer_threads << Thread.new {  
consumer = Consumer.new(sized_
queue, stdout_mutex)  
consumer.consume  
}  
Thread.new {  
producer = Producer.new(sized_
queue, stdout_mutex)  
producer.produce  
}  
}  
consumer_threads.each { 
|thread| thread.join } 

上述就是小編為大家分享的如何進(jìn)行Ruby線程相關(guān)知識(shí)點(diǎn)分析了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。