Lines Matching refs:Thread
40 unless defined? Thread
41 raise "Thread not available for this ruby interpreter"
60 Message = "Thread(%s) not locked."
138 Thread.handle_interrupt(StandardError => :on_blocking) do
145 if sync_sh_locker[Thread.current]
146 sync_upgrade_waiting.push [Thread.current, sync_sh_locker[Thread.current]]
147 sync_sh_locker.delete(Thread.current)
149 unless sync_waiting.include?(Thread.current) || sync_upgrade_waiting.reverse_each.any?{|w| w.first == Thread.current }
150 sync_waiting.push Thread.current
156 sync_waiting.delete(Thread.current)
168 Err::UnknownLocker.Fail(Thread.current)
176 Err::UnknownLocker.Fail(Thread.current)
179 if sync_ex_locker == Thread.current
182 if sync_sh_locker.include?(Thread.current)
190 Err::UnknownLocker.Fail(Thread.current)
194 if (count = sync_sh_locker[Thread.current]).nil?
195 Err::UnknownLocker.Fail(Thread.current)
197 if (sync_sh_locker[Thread.current] = count - 1) == 0
198 sync_sh_locker.delete(Thread.current)
230 Thread.handle_interrupt(StandardError => :on_blocking) do
277 sync_sh_locker[Thread.current] = 1
280 count = 0 unless count = sync_sh_locker[Thread.current]
281 sync_sh_locker[Thread.current] = count + 1
285 if sync_ex_locker == Thread.current
294 sync_mode == SH && sync_sh_locker.size == 1 && sync_sh_locker.include?(Thread.current)
296 self.sync_ex_locker = Thread.current
299 elsif sync_mode == EX && sync_ex_locker == Thread.current