module Reacto::Executors

Public Instance Methods

current() click to toggle source
# File lib/reacto/executors.rb, line 13
def current
  immediate
end
immediate() click to toggle source
# File lib/reacto/executors.rb, line 9
def immediate
  @immediate ||= Concurrent::ImmediateExecutor.new
end
io() click to toggle source
# File lib/reacto/executors.rb, line 17
def io
  @io ||= Concurrent::CachedThreadPool.new
end
new_thread() click to toggle source
# File lib/reacto/executors.rb, line 25
def new_thread
  @new_thread ||= Concurrent::SimpleExecutorService.new
end
tasks() click to toggle source
# File lib/reacto/executors.rb, line 21
def tasks
  @tasks ||= Concurrent::FixedThreadPool.new(4) # Number of cores here?
end