# 線程 #1 代碼部分
Thread.new {
 # 線程 #2 執(zhí)行代碼
}
# 線程 #1 執(zhí)行代碼

#!/usr/bin/ruby
 
def func1
  i=0
  while i<=2
   puts "func1 at: #{Time.now}"
   sleep(2)
   i=i+1
  end
end
 
def func2
  j=0
  while j<=2
   puts "func2 at: #{Time.now}"
   sleep(1)
   j=j+1
  end
end
 
puts "Started At #{Time.now}"
t1=Thread.new{func1()}
t2=Thread.new{func2()}
t1.join
t2.join
puts "End at #{Time.now}"

Started At Wed May 14 08:21:54 -0700 2014
func1 at: Wed May 14 08:21:54 -0700 2014
func2 at: Wed May 14 08:21:54 -0700 2014
func2 at: Wed May 14 08:21:55 -0700 2014
func1 at: Wed May 14 08:21:56 -0700 2014
func2 at: Wed May 14 08:21:56 -0700 2014
func1 at: Wed May 14 08:21:58 -0700 2014
End at Wed May 14 08:22:00 -0700 2014

begin
 t = Thread.new do
  Thread.pass  # 主線程確實(shí)在等join
  raise "unhandled exception"
 end
 t.join
rescue
 p $! # => "unhandled exception"
end

t = Thread.new { ... }
t.abort_on_exception = true

#encoding:gbk
require "thread"
puts "Synchronize Thread"
 
@num=200
@mutex=Mutex.new
 
def buyTicket(num)
  @mutex.lock
    if @num>=num
      @num=@num-num
      puts "you have successfully bought #{num} tickets"
    else
      puts "sorry,no enough tickets"
    end
  @mutex.unlock
end
 
ticket1=Thread.new 10 do
  10.times do |value|
  ticketNum=15
  buyTicket(ticketNum)
  sleep 0.01
  end
end
 
ticket2=Thread.new 10 do
  10.times do |value|
  ticketNum=20
  buyTicket(ticketNum)
  sleep 0.01
  end
end
 
sleep 1
ticket1.join
ticket2.join

Synchronize Thread
you have successfully bought 15 tickets
you have successfully bought 20 tickets
you have successfully bought 15 tickets
you have successfully bought 20 tickets
you have successfully bought 15 tickets
you have successfully bought 20 tickets
you have successfully bought 15 tickets
you have successfully bought 20 tickets
you have successfully bought 15 tickets
you have successfully bought 20 tickets
you have successfully bought 15 tickets
sorry,no enough tickets
sorry,no enough tickets
sorry,no enough tickets
sorry,no enough tickets
sorry,no enough tickets
sorry,no enough tickets
sorry,no enough tickets
sorry,no enough tickets
sorry,no enough tickets

#encoding:gbk
require "thread"
puts "SizedQuee Test"
 
queue = Queue.new
 
producer = Thread.new do
  10.times do |i|
    sleep rand(i) # 讓線程睡眠一段時(shí)間
    queue << i
    puts "#{i} produced"
  end
end
 
consumer = Thread.new do
  10.times do |i|
    value = queue.pop
    sleep rand(i/2)
    puts "consumed #{value}"
  end
end
 
consumer.join

程序的輸出：
SizedQuee Test
0 produced
1 produced
consumed 0
2 produced
consumed 1
consumed 2
3 produced
consumed 34 produced
 
consumed 4
5 produced
consumed 5
6 produced
consumed 6
7 produced
consumed 7
8 produced
9 produced
consumed 8
consumed 9

#encoding:gbk
require "thread"
puts "thread synchronize by ConditionVariable"
 
mutex = Mutex.new
resource = ConditionVariable.new
 
a = Thread.new {
  mutex.synchronize {
    # 這個(gè)線程目前需要resource這個(gè)資源
    resource.wait(mutex)
    puts "get resource"
  }
}
 
b = Thread.new {
  mutex.synchronize {
    #線程b完成對(duì)resourece資源的使用并釋放resource
    resource.signal
  }
}
 
a.join
puts "complete"

thread synchronize by ConditionVariable
get resource
complete

#!/usr/bin/ruby
 
thr = Thread.new do  # 實(shí)例化
  puts "In second thread"
  raise "Raise exception"
end
thr.join  # 調(diào)用實(shí)例化方法 join

#!/usr/bin/ruby
 
thr = Thread.new do  # 實(shí)例化
  puts "In second thread"
  raise "Raise exception"
end
thr.join  # 調(diào)用實(shí)例化方法 join