We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 026641c commit 199314fCopy full SHA for 199314f
lib/concurrent/actor/simple_actor_ref.rb
@@ -11,7 +11,7 @@ class SimpleActorRef
11
def initialize(actor, opts = {})
12
@actor = actor
13
@mutex = Mutex.new
14
- @executor = SingleThreadExecutor.new
+ @executor = OneByOne.new OptionsParser::get_executor_from(opts)
15
@stop_event = Event.new
16
@reset_on_error = opts.fetch(:reset_on_error, true)
17
@exception_class = opts.fetch(:rescue_exception, false) ? Exception : StandardError
@@ -51,7 +51,6 @@ def post!(timeout, *msg)
51
def shutdown
52
@mutex.synchronize do
53
return if shutdown?
54
- @executor.shutdown
55
@actor.on_shutdown
56
@stop_event.set
57
end
0 commit comments