blob: 823888e72f21c6e714064502ad10227c18e93208 (
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
|
#
# mutex_m.rb -
# $Release Version: 2.0$
# $Revision: 1.2 $
# $Date: 1997/07/25 02:43:21 $
# Original from mutex.rb
# by Keiju ISHITSUKA(SHL Japan Inc.)
#
# --
# Usage:
# require "mutex_m.rb"
# obj = Object.new
# obj.extend Mutex_m
# ...
# 後はMutexと同じ使い方
#
require "finalize"
module Mutex_m
def Mutex_m.extend_object(obj)
if Fixnum === obj or TRUE === obj or FALSE === obj or nil == obj
raise TypeError, "Mutex_m can't extend to this class(#{obj.type})"
else
begin
eval "class << obj
@mu_locked
end"
obj.extend(For_primitive_object)
rescue TypeError
obj.extend(For_general_object)
end
end
end
def mu_extended
unless (defined? locked? and
defined? lock and
defined? unlock and
defined? try_lock and
defined? synchronize)
eval "class << self
alias locked mu_locked?
alias lock mu_lock
alias unlock mu_unlock
alias try_lock mu_try_lock
alias synchronize mu_synchronize
end"
end
end
def mu_synchronize
begin
mu_lock
yield
ensure
mu_unlock
end
end
module For_general_object
include Mutex_m
def For_general_object.extend_object(obj)
super
obj.mu_extended
end
def mu_extended
super
@mu_waiting = []
@mu_locked = FALSE;
end
def mu_locked?
@mu_locked
end
def mu_try_lock
result = FALSE
Thread.critical = TRUE
unless @mu_locked
@mu_locked = TRUE
result = TRUE
end
Thread.critical = FALSE
result
end
def mu_lock
while (Thread.critical = TRUE; @mu_locked)
@mu_waiting.push Thread.current
Thread.stop
end
@mu_locked = TRUE
Thread.critical = FALSE
self
end
def mu_unlock
return unless @mu_locked
Thread.critical = TRUE
wait = @mu_waiting
@mu_waiting = []
@mu_locked = FALSE
Thread.critical = FALSE
for w in wait
w.run
end
self
end
end
module For_primitive_object
include Mutex_m
Mu_Locked = Hash.new
def For_primitive_object.extend_object(obj)
super
obj.mu_extended
Finalizer.add(obj, For_primitive_object, :mu_finalize)
end
def For_primitive_object.mu_finalize(id)
Thread.critical = TRUE
if wait = Mu_Locked.delete(id)
# wait == [] ときだけ GCされるので, for w in wait は意味なし.
Thread.critical = FALSE
for w in wait
w.run
end
else
Thread.critical = FALSE
end
self
end
def mu_locked?
Mu_Locked.key?(self.id)
end
def mu_try_lock
Thread.critical = TRUE
if Mu_Locked.key?(self.id)
ret = FALSE
else
Mu_Locked[self.id] = []
Finalizer.set(self, For_primitive_object, :mu_delete_Locked)
ret = TRUE
end
Thread.critical = FALSE
ret
end
def mu_lock
while (Thread.critical = TRUE; w = Mu_Locked[self.id])
w.push Thread.current
Thread.stop
end
Mu_Locked[self.id] = []
Finalizer.add(self, For_primitive_object, :mu_delete_Locked)
Thread.critical = FALSE
self
end
def mu_unlock
Thread.critical = TRUE
if wait = Mu_Locked.delete(self.id)
Finalizer.delete(self, For_primitive_object, :mu_finalize)
Thread.critical = FALSE
for w in wait
w.run
end
else
Thread.critical = FALSE
end
self
end
end
end
|
