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