ruby线程问题——同步篇

雷欧纳德

=begin
    脚本：【线程同步类】
    功能：对使用ruby多线程编程时，对临界资源进行同步操作的类。
    说明: 对于不同线程访问临界资源(公共变量等)时，应进行同步。
          步骤：
          1、创建Mutex对象；
          2、在线程内要访问临界资源的地方调用Mutex(互斥)对象的同步方法进行同步。
          e.g.： lock = Mutex.new
                 lock.synchronize{
                   # 中间即要同步的块
                 }
    作者：灼眼的夏娜
    版本：v1.0。
=end

1. #==============================================================================
   
2. # ■ Mutex
   
3. #------------------------------------------------------------------------------
   
4. # 　互斥锁的类。
   
5. #==============================================================================
   
6. class Mutex
   
7.   
   
8.     #--------------------------------------------------------------------------
   
9.     # ● 初始化
   
10.     #--------------------------------------------------------------------------
    
11.     def initialize
    
12.       @synchronizing = false
    
13.       @waiting_threads = Array.new
    
14.     end
    
15.   
    
16.     #--------------------------------------------------------------------------
    
17.     # ● 同步块
    
18.     #--------------------------------------------------------------------------
    
19.     def synchronize
    
20.       Thread.critical = true
    
21.       if @synchronizing
    
22.         @waiting_threads << Thread.current
    
23.         Thread.stop
    
24.       end
    
25.       @synchronizing = true
    
26.       Thread.critical = false
    
27.       yield
    
28.       Thread.critical = true
    
29.       next_thread = @waiting_threads.shift
    
30.       if next_thread.nil?
    
31.         @synchronizing = false
    
32.       else
    
33.         next_thread.run
    
34.       end
    
35.       Thread.critical = false
    
36.     end
    
37.   
    
38. end

复制代码

以下举例：

1、未同步的情况：

1. apples = 5
   
2. 
   
3. t1 = Thread.new do
   
4.     while true
   
5.       if apples > 0
   
6.         sleep(0.001)
   
7.         p "Thread01 get the #{6 - apples}th apple."
   
8.         apples -= 1
   
9.         if apples == 0
   
10.           break
    
11.         end
    
12.       end
    
13.     end
    
14. end
    
15. 
    
16. t2 = Thread.new do
    
17.     while true
    
18.       if apples > 0
    
19.         sleep(0.001)
    
20.         p "Thread02 get the #{6 - apples}th apple."
    
21.         apples -= 1
    
22.         if apples == 0
    
23.           break
    
24.         end
    
25.       end
    
26.     end
    
27. end

复制代码

可以看到线程01得到了第六个苹果- -bb，显然出错了。

2、同步的情况：

1. apples = 5
   
2. 
   
3. mu_obj = Mutex.new # 创建互斥对象
   
4. 
   
5. t1 = Thread.new do
   
6.     while true
   
7.     mu_obj.synchronize do # 同步块
   
8.         if apples > 0
   
9.           sleep(0.001)
   
10.           p "Thread01 get the #{6 - apples}th apple."
    
11.           apples -= 1
    
12.           if apples == 0
    
13.             break
    
14.           end
    
15.         end
    
16.     end
    
17.     end
    
18. end
    
19. 
    
20. t2 = Thread.new do
    
21.     while true
    
22.     mu_obj.synchronize do # 同步块
    
23.         if apples > 0
    
24.           sleep(0.001)
    
25.           p "Thread02 get the #{6 - apples}th apple."
    
26.           apples -= 1
    
27.           if apples == 0
    
28.             break
    
29.           end
    
30.         end
    
31.     end
    
32.     end
    
33. end

复制代码

此时就正常了。。= =bbb

如果有什么问题 欢迎补充。

雷欧纳德

=begin

    脚本：【线程同步类】
  
    功能：对使用ruby多线程编程时，对临界资源进行同步操作的类。
  
    说明: 对于不同线程访问临界资源(公共变量等)时，应进行同步。
  
          步骤：
          1、创建Mutex对象；
          2、在线程内要访问临界资源的地方调用Mutex(互斥)对象的同步方法进行同步。
        
          e.g.： lock = Mutex.new
        
                 lock.synchronize{
                   # 中间即要同步的块
                 }

    作者：灼眼的夏娜
  
    版本：v1.0。

=end

#==============================================================================
# ■ Mutex
#------------------------------------------------------------------------------
# 　互斥锁的类。
#==============================================================================
class Mutex
  
    #--------------------------------------------------------------------------
    # ● 初始化
    #--------------------------------------------------------------------------
    def initialize
      @synchronizing = false
      @waiting_threads = Array.new
    end
  
    #--------------------------------------------------------------------------
    # ● 同步块
    #--------------------------------------------------------------------------
    def synchronize
      Thread.critical = true
      if @synchronizing
        @waiting_threads << Thread.current
        Thread.stop
      end
      @synchronizing = true
      Thread.critical = false
      yield
      Thread.critical = true
      next_thread = @waiting_threads.shift
      if next_thread.nil?
        @synchronizing = false
      else
        next_thread.run
      end
      Thread.critical = false
    end
  
end

以下举例：

1、未同步的情况：

apples = 5

t1 = Thread.new do
    while true
      if apples > 0
        sleep(0.001)
        p "Thread01 get the #{6 - apples}th apple."
        apples -= 1
        if apples == 0
          break
        end
      end
    end
end

t2 = Thread.new do
    while true
      if apples > 0
        sleep(0.001)
        p "Thread02 get the #{6 - apples}th apple."
        apples -= 1
        if apples == 0
          break
        end
      end
    end
end

可以看到线程01得到了第六个苹果- -bb，显然出错了。

2、同步的情况：

apples = 5

mu_obj = Mutex.new # 创建互斥对象

t1 = Thread.new do
    while true
    mu_obj.synchronize do # 同步块
        if apples > 0
          sleep(0.001)
          p "Thread01 get the #{6 - apples}th apple."
          apples -= 1
          if apples == 0
            break
          end
        end
    end
    end
end

t2 = Thread.new do
    while true
    mu_obj.synchronize do # 同步块
        if apples > 0
          sleep(0.001)
          p "Thread02 get the #{6 - apples}th apple."
          apples -= 1
          if apples == 0
            break
          end
        end
    end
    end
end

此时就正常了。。= =bbb

如果有什么问题 欢迎补充。

叶子

{/fd}Isn't the Mutex class built in the thread.rb?
http://www.ruby-doc.org/stdlib/libdoc/thread/rdoc/index.html

九泪

你们两位哟！

我进来参和参和。不能让你们两个在凌晨时分眉来眼去....{/gg}

亿万星辰

感觉这个在游戏制作中不会用到.........{/hx}

只在操作系统还是什么课里学过线程.....{/hx}

雷欧纳德

以下引用亿万星辰于2007-6-5 7:28:29的发言：

感觉这个在游戏制作中不会用到.........

只在操作系统还是什么课里学过线程.....

操作系统。。。。昨天在学的人路过。。。。

ю殘劒唫轌Θ

发现小夏？MS很久没有出现的说……………………抓住！

金圭子

以下引用亿万星辰于2007-6-5 7:28:29的发言：

感觉这个在游戏制作中不会用到.........

只在操作系统还是什么课里学过线程.....

操作系统，也就是P操作和V操作：
当时我还用flash给老师做了个演示动画，所以记忆很深刻……

尤莉斯

以下引用叶子于2007-6-5 1:32:04的发言：

Isn't the Mutex class built in the thread.rb?
http://www.ruby-doc.org/stdlib/libdoc/thread/rdoc/index.html

{/gg}

以下引用亿万星辰于2007-6-5 7:28:29的发言：

感觉这个在游戏制作中不会用到.........

只在操作系统还是什么课里学过线程.....

{/cy}在处理一些网络连接什么什么的之类的 很多地方ms还素可以用的说= =

亿万星辰

以下引用尤莉斯于2007-6-5 15:25:26的发言：
在处理一些网络连接什么什么的之类的 很多地方ms还素可以用的说= =

完全不打算涉足RM网络游戏制作的某人飘过.......{/hx}