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
|
require 'concurrent/utility/engine'
require_relative 'fiber_local_var'
require_relative 'thread_local_var'
module Concurrent
# @!visibility private
def self.mutex_owned_per_thread?
return false if Concurrent.on_jruby? || Concurrent.on_truffleruby?
mutex = Mutex.new
# Lock the mutex:
mutex.synchronize do
# Check if the mutex is still owned in a child fiber:
Fiber.new { mutex.owned? }.resume
end
end
if mutex_owned_per_thread?
LockLocalVar = ThreadLocalVar
else
LockLocalVar = FiberLocalVar
end
# Either {FiberLocalVar} or {ThreadLocalVar} depending on whether Mutex (and Monitor)
# are held, respectively, per Fiber or per Thread.
class LockLocalVar
end
end
|
