File tree Expand file tree Collapse file tree 2 files changed +8
-3
lines changed Expand file tree Collapse file tree 2 files changed +8
-3
lines changed Original file line number Diff line number Diff line change 1
1
require 'thread'
2
2
require 'concurrent/delay'
3
3
require 'concurrent/errors'
4
+ require 'concurrent/atomic/atomic'
4
5
require 'concurrent/executor/thread_pool_executor'
5
6
require 'concurrent/executor/timer_set'
6
7
require 'concurrent/utility/processor_count'
@@ -111,8 +112,12 @@ def new_operation_pool
111
112
end
112
113
113
114
# create the default configuration on load
114
- @configuration = Configuration . new
115
- singleton_class . send :attr_reader , :configuration
115
+ @configuration = Atomic . new Configuration . new
116
+
117
+ # @return [Configuration]
118
+ def self . configuration
119
+ @configuration . value
120
+ end
116
121
117
122
# Perform gem-level configuration.
118
123
#
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ def rbx?
24
24
25
25
def reset_gem_configuration
26
26
return if @do_not_reset
27
- Concurrent . instance_variable_set ( :@configuration , Concurrent ::Configuration . new )
27
+ Concurrent . instance_variable_get ( :@configuration ) . value = Concurrent ::Configuration . new
28
28
end
29
29
30
30
def kill_rogue_threads ( warning = true )
You can’t perform that action at this time.
0 commit comments