File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -9,6 +9,7 @@ module Concurrent
9
9
# monitors the set and schedules each task for execution at the appropriate
10
10
# time. Tasks are run on the global task pool or on the supplied executor.
11
11
class TimerSet
12
+ include OptionsParser
12
13
13
14
# Create a new set of timed tasks.
14
15
#
@@ -22,7 +23,7 @@ def initialize(opts = {})
22
23
@mutex = Mutex . new
23
24
@shutdown = Event . new
24
25
@queue = PriorityQueue . new ( order : :min )
25
- @executor = OptionsParser :: get_executor_from ( opts )
26
+ @executor = get_executor_from ( opts )
26
27
@thread = nil
27
28
end
28
29
@@ -142,7 +143,7 @@ def check_processing_thread!
142
143
@thread . wakeup
143
144
elsif @thread . nil? || ! @thread . alive?
144
145
@thread = Thread . new do
145
- Thread . current . abort_on_exception = false
146
+ Thread . current . abort_on_exception = true
146
147
process_tasks
147
148
end
148
149
end
Original file line number Diff line number Diff line change @@ -20,6 +20,5 @@ def get_executor_from(opts = {})
20
20
Concurrent . configuration . global_task_pool
21
21
end
22
22
end
23
- module_function :get_executor_from
24
23
end
25
24
end
Original file line number Diff line number Diff line change 21
21
Dir [ File . join ( File . dirname ( __FILE__ ) , 'support/**/*.rb' ) ] . each { |f | require File . expand_path ( f ) }
22
22
23
23
RSpec . configure do |config |
24
- # config.order = 'random'
24
+ config . order = 'random'
25
25
26
26
config . before ( :suite ) do
27
27
end
You can’t perform that action at this time.
0 commit comments