Ruby 多线程

Ruby 多线程每个正在系统上运行的程序都是一个进程。每个进程包含一到多个线程。线程是程序中一个单一的顺序控制流程，在单个程序中同时运行多个线程完成不同的工作,称为多线程。Ruby 中我们可以通过 Thread 类来创建多线程，Ruby的线程是一个轻量级的，可以以高效的方式来实现并行的代码。创建 Ruby 线程要启动一个新的线程，只需要调用 Thread.new 即可:











# 线程





#1 代码部分Thread.new {





# 线程





#2 执行代码}





# 线程





#1 执行代码实例以下实例展示了如何在Ruby程序中使用多线程：实例





#!/usr/bin/rubydef func1i=0while i<=2puts "func1 at:











#{Time.now}"sleep(2)i=i+1endenddef func2j=0while j<=2puts "func2 at:











#{Time.now}"sleep(1)j=j+1endendputs "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 2014func1 at:





Wed May 14 08:





21:





54 -0700 2014func2 at:





Wed May 14 08:





21:





54 -0700 2014func2 at:





Wed May 14 08:





21:





55 -0700 2014func1 at:





Wed May 14 08:





21:





56 -0700 2014func2 at:





Wed May 14 08:





21:





56 -0700 2014func1 at:





Wed May 14 08:





21:





58 -0700 2014End at Wed May 14 08:





22:





00 -0700 2014线程生命周期1、线程的创建可以使用Thread.new,同样可以以同样的语法使用Thread.start 或者Thread.fork这三个方法来创建线程。2、创建线程后无需启动，线程会自动执行。3、Thread 类定义了一些方法来操控线程。线程执行Thread.new中的代码块。4、线程代码块中最后一个语句是线程的值，可以通过线程的方法来调用，如果线程执行完毕，则返回线程值，否则不返回值直到线程执行完毕。5、Thread.current 方法返回表示当前线程的对象。 Thread.main 方法返回主线程。6、通过 Thread.Join 方法来执行线程，这个方法会挂起主线程，直到当前线程执行完毕。线程状态线程有5种状态：线程状态返回值可执行run睡眠Sleeping退出aborting正常终止false 发生异常终止nil 线程和异常当某线程发生异常，且没有被rescue捕捉到时，该线程通常会被无警告地终止。但是，若有其它线程因为Thread





#join的关系一直等待该线程的话，则等待的线程同样会被引发相同的异常。begint = Thread.new doThread.pass





# 主线程确实在等joinraise "unhandled exception"endt.joinrescuep $!





# => "unhandled exception"end使用下列3个方法，就可以让解释器在某个线程因异常而终止时中断运行。启动脚本时指定-d选项，并以调试模时运行。用Thread.abort_on_exception设置标志。使用Thread





#abort_on_exception对指定的线程设定标志。当使用上述3种方法之一后，整个解释器就会被中断。t = Thread.new { ... }t.abort_on_exception = true线程同步控制在Ruby中，提供三种实现同步的方式，分别是：1. 通过Mutex类实现线程同步2. 监管数据交接的Queue类实现线程同步3. 使用ConditionVariable实现同步控制通过Mutex类实现线程同步通过Mutex类实现线程同步控制，如果在多个线程钟同时需要一个程序变量，可以将这个变量部分使用lock锁定。代码如下：实例





#!/usr/bin/rubyrequire "thread"puts "Synchronize Thread"@num=200@mutex=Mutex.newdef buyTicket(num)@mutex.lockif @num>=num@num=@num-numputs "you have successfully bought





#{num} tickets"elseputs "sorry,no enough tickets"end@mutex.unlockendticket1=Thread.new 10 do10.times do |value|ticketNum=15buyTicket(ticketNum)sleep 0.01endendticket2=Thread.new 10 do10.times do |value|ticketNum=20buyTicket(ticketNum)sleep 0.01endendsleep 1ticket1.jointicket2.join尝试一下 ?以上代码执行结果为：Synchronize Threadyou have successfully bought 15 ticketsyou have successfully bought 20 ticketsyou have successfully bought 15 ticketsyou have successfully bought 20 ticketsyou have successfully bought 15 ticketsyou have successfully bought 20 ticketsyou have successfully bought 15 ticketsyou have successfully bought 20 ticketsyou have successfully bought 15 ticketsyou have successfully bought 20 ticketsyou have successfully bought 15 ticketssorry,no enough ticketssorry,no enough ticketssorry,no enough ticketssorry,no enough ticketssorry,no enough ticketssorry,no enough ticketssorry,no enough ticketssorry,no enough ticketssorry,no enough tickets除了使用lock锁定变量，还可以使用try_lock锁定变量，还可以使用Mutex.synchronize同步对某一个变量的访问。监管数据交接的Queue类实现线程同步Queue类就是表示一个支持线程的队列，能够同步对队列末尾进行访问。不同的线程可以使用统一个对类，但是不用担心这个队列中的数据是否能够同步，另外使用SizedQueue类能够限制队列的长度SizedQueue类能够非常便捷的帮助我们开发线程同步的应用程序，应为只要加入到这个队列中，就不用关心线程的同步问题。经典的生产者消费者问题：实例





#!/usr/bin/rubyrequire "thread"puts "SizedQuee Test"queue = Queue.newproducer = Thread.new do10.times do |i|sleep rand(i)





# 让线程睡眠一段时间queue << iputs "





#{i} produced"endendconsumer = Thread.new do10.times do |i|value = queue.popsleep rand(i/2)puts "consumed





#{value}"endendconsumer.join尝试一下 ?程序的输出：SizedQuee Test0 produced1 producedconsumed 02 producedconsumed 1consumed 23 producedconsumed 34 producedconsumed 45 producedconsumed 56 producedconsumed 67 producedconsumed 78 produced9 producedconsumed 8consumed 9线程变量线程可以有其私有变量，线程的私有变量在线程创建的时候写入线程。可以被线程范围内使用，但是不能被线程外部进行共享。但是有时候，线程的局部变量需要别别的线程或者主线程访问怎么办？ruby当中提供了允许通过名字来创建线程变量，类似的把线程看做hash式的散列表。通过[]=写入并通过[]读出数据。我们来看一下下面的代码：实例





#!/usr/bin/rubycount = 0arr = []10.times do |i|arr[i] = Thread.ne