傳統程序有一個單獨的線程執行,包含該程序的語句或指令順序執行直到程序終止。
一個多線程的程序有多個線程的執行。在每個線程是按順序執行的,但是在多核CPU機器上線程可能并行地執行。例如,通常情況下在單一CPU的機器,多個線程實際上不是并行執行的,而是模擬并行交叉的線程的執行。
Ruby的可以使用 Thread 類很容易地編寫多線程程序。 Ruby線程是一個輕量級的和高效的在代碼中實現并行性。
創建Ruby線程:
要啟動一個新線程,關聯一個塊通過調用Thread.new。將創建一個新的線程執行的代碼塊,原始線程將立即從Thread.new返回并繼續執行下一個語句:
# Thread #1 is running hereThread.new { # Thread #2 runs this code}# Thread #1 runs this code
例如:
這里是一個例子說明,我們如何能夠利用多線程的Ruby的程序。
#!/usr/bin/rubydef func1 i=0 while i<=2 puts "func1 at: #{Time.now}" sleep(2) i=i+1 endenddef func2 j=0 while j<=2 puts "func2 at: #{Time.now}" sleep(1) j=j+1 endendputs "Started At #{Time.now}"t1=Thread.new{func1()}t2=Thread.new{func2()}t1.joint2.joinputs "End at #{Time.now}"
這將產生以下結果:
Started At Wed May 14 08:21:54 -0700 2008func1 at: Wed May 14 08:21:54 -0700 2008func2 at: Wed May 14 08:21:54 -0700 2008func2 at: Wed May 14 08:21:55 -0700 2008func1 at: Wed May 14 08:21:56 -0700 2008func2 at: Wed May 14 08:21:56 -0700 2008func1 at: Wed May 14 08:21:58 -0700 2008End at Wed May 14 08:22:00 -0700 2008
線程的生命周期:
創建一個新的線程用 Thread.new。也可以使用了同義詞用 Thread.Start 和 Thread.fork。
沒有必要啟動一個線程在它被創建后,它會自動開始運行時,CPU 資源成為可用。
Thread 類定義了一些方法來查詢和處理的線程在運行時。運行一個線程塊中的代碼調用Thread.new,然后它停止運行。
該塊中的最后一個表達式的值是線程的值,可以通過調用 Thread對象值的方法。如果線程運行完成,則該值為線程的返回值。否則,該值方法會阻塞不會返回,直到該線程已完成。
類方法Thread.current返回代表當前線程的 Thread對象。這允許線程操縱自己。類方法 Thread.main返回線程對象代表主線程,thread.this初始線程開始執行Ruby程序開始時。
可以等待一個特定的線程通過調用該線程的Thread.Join方法來完成。調用線程將被阻塞,直到給定線程完成。
線程和異常:
如果在主線程中引發一個異常,并沒有任何地方處理,Ruby解釋器打印一條消息并退出。在主線程以外的其他線程,未處理的異常導致線程停止運行。
如果線程 t 退出,因為未處理的異常,而另一個線程調用t.join或t.value,那么所發生的異常在 t 中提出的線程 s。
新聞熱點
疑難解答