File tree Expand file tree Collapse file tree 1 file changed +7
-7
lines changed
lib/concurrent/synchronization Expand file tree Collapse file tree 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -2,12 +2,12 @@ module Concurrent
2
2
module Synchronization
3
3
4
4
if Concurrent . on_rbx?
5
-
5
+
6
6
# @!visibility private
7
7
# @!macro internal_implementation_note
8
8
class RbxObject < AbstractObject
9
9
def initialize
10
- @RbxWaiters = [ ]
10
+ @__Waiters__ = [ ]
11
11
ensure_ivar_visibility!
12
12
end
13
13
@@ -21,29 +21,29 @@ def ns_wait(timeout = nil)
21
21
wchan = Rubinius ::Channel . new
22
22
23
23
begin
24
- @RbxWaiters . push wchan
24
+ @__Waiters__ . push wchan
25
25
Rubinius . unlock ( self )
26
26
signaled = wchan . receive_timeout timeout
27
27
ensure
28
28
Rubinius . lock ( self )
29
29
30
- if !signaled && !@RbxWaiters . delete ( wchan )
30
+ if !signaled && !@__Waiters__ . delete ( wchan )
31
31
# we timed out, but got signaled afterwards,
32
32
# so pass that signal on to the next waiter
33
- @RbxWaiters . shift << true unless @RbxWaiters . empty?
33
+ @__Waiters__ . shift << true unless @__Waiters__ . empty?
34
34
end
35
35
end
36
36
37
37
self
38
38
end
39
39
40
40
def ns_signal
41
- @RbxWaiters . shift << true unless @RbxWaiters . empty?
41
+ @__Waiters__ . shift << true unless @__Waiters__ . empty?
42
42
self
43
43
end
44
44
45
45
def ns_broadcast
46
- @RbxWaiters . shift << true until @RbxWaiters . empty?
46
+ @__Waiters__ . shift << true until @__Waiters__ . empty?
47
47
self
48
48
end
49
49
You can’t perform that action at this time.
0 commit comments