File tree Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Expand file tree Collapse file tree 2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -131,8 +131,6 @@ def self.global_immediate_executor
131
131
# Global thread pool user for global *timers*.
132
132
#
133
133
# @return [Concurrent::TimerSet] the thread pool
134
- #
135
- # @see Concurrent::timer
136
134
def self . global_timer_set
137
135
GLOBAL_TIMER_SET . value
138
136
end
Original file line number Diff line number Diff line change @@ -297,13 +297,14 @@ def kill_execution
297
297
298
298
# @!visibility private
299
299
def schedule_next_task ( interval = execution_interval )
300
- Concurrent ::timer ( interval , Concurrent ::Event . new , &method ( :execute_task ) )
300
+ ScheduledTask . execute ( interval , args : [ Concurrent ::Event . new ] , &method ( :execute_task ) )
301
+ nil
301
302
end
302
303
303
304
# @!visibility private
304
305
def execute_task ( completion )
305
- return unless @running . true?
306
- Concurrent :: timer ( execution_interval , completion , &method ( :timeout_task ) )
306
+ return nil unless @running . true?
307
+ ScheduledTask . execute ( execution_interval , args : [ completion ] , &method ( :timeout_task ) )
307
308
_success , value , reason = @executor . execute ( self )
308
309
if completion . try?
309
310
self . value = value
@@ -313,6 +314,7 @@ def execute_task(completion)
313
314
[ time , self . value , reason ]
314
315
end
315
316
end
317
+ nil
316
318
end
317
319
318
320
# @!visibility private
You can’t perform that action at this time.
0 commit comments