Sha256: 494ec27fc8d14afed4daf61afc570fcfbbd96a626bb6271736adb64f830ac668
Contents?: true
Size: 607 Bytes
Versions: 163
Compression:
Stored size: 607 Bytes
Contents
require 'concurrent/executor/ruby_thread_pool_executor'
module Concurrent
# @!macro single_thread_executor
# @!macro abstract_executor_service_public_api
# @!visibility private
class RubySingleThreadExecutor < RubyThreadPoolExecutor
# @!macro single_thread_executor_method_initialize
def initialize(opts = {})
super(
min_threads: 1,
max_threads: 1,
max_queue: 0,
idletime: DEFAULT_THREAD_IDLETIMEOUT,
fallback_policy: opts.fetch(:fallback_policy, :discard),
auto_terminate: opts.fetch(:auto_terminate, true)
)
end
end
end
Version data entries
163 entries across 150 versions & 33 rubygems