class Reacto::Resources::ExecutorResource
Public Class Methods
new(executor, threads: [])
click to toggle source
# File lib/reacto/resources/executor_resource.rb, line 4 def initialize(executor, threads: []) @executor = executor @threads = threads end
Public Instance Methods
cleanup()
click to toggle source
# File lib/reacto/resources/executor_resource.rb, line 9 def cleanup @executor.shutdown unless @executor.nil? @executor = nil @threads.each do |thread| Thread.kill(thread) end @threads = [] end