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