summaryrefslogtreecommitdiff
path: root/lib/rbot/compat19.rb
blob: c32d1ecbf98544709b6e5d92cf8ed98dbe6c1e96 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
#-- vim:sw=2:et
#++
#
# :title: ruby 1.9 compatibility (monkey)patches

require 'timeout'
require "thread"

class ConditionVariable

  def wait(mutex, timeout=nil)
    begin
      # TODO: mutex should not be used
      @waiters_mutex.synchronize do
        @waiters.push(Thread.current)
      end
      if timeout
        elapsed = mutex.sleep timeout if timeout > 0.0
        unless timeout > 0.0 and elapsed < timeout
          t = @waiters_mutex.synchronize { @waiters.delete Thread.current }
          signal unless t # if we got notified, pass it along
          raise TimeoutError, "wait timed out"
        end
      else
        mutex.sleep
      end
    end
    nil
  end

end

require 'monitor'

module MonitorMixin

  class ConditionVariable

    def wait(timeout = nil)
      #if timeout
      #  raise NotImplementedError, "timeout is not implemented yet"
      #end
      @monitor.__send__(:mon_check_owner)
      count = @monitor.__send__(:mon_exit_for_cond)
      begin
        @cond.wait(@monitor.instance_variable_get("@mon_mutex"), timeout)
        return true
      rescue TimeoutError
        return false
      ensure
        @monitor.__send__(:mon_enter_for_cond, count)
      end
    end

    def signal
      @monitor.__send__(:mon_check_owner)
      @cond.signal
    end

    def broadcast
      @monitor.__send__(:mon_check_owner)
      @cond.broadcast
    end

  end  # ConditionVariable

  def self.extend_object(obj)
    super(obj)
    obj.__send__(:mon_initialize)
  end

end # MonitorMixin