Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 4 additions & 2 deletions lib/leopard/nats_api_server.rb
Original file line number Diff line number Diff line change
Expand Up @@ -138,7 +138,7 @@ def shutdown(workers, pool)
logger.warn 'Pool is shut down, waiting for termination!'
pool.wait_for_termination
logger.warn 'Bye bye!'
wake_main_thread
wake_main_thread_and_exit!
end
end

Expand All @@ -165,10 +165,12 @@ def trap_signals(workers, pool)
# If the main thread is not blocked, this method does nothing.
#
# @return [void]
def wake_main_thread
def wake_main_thread_and_exit!
Thread.main.wakeup
rescue ThreadError
nil
ensure
exit
Comment thread
bougyman marked this conversation as resolved.
Outdated
end
end

Expand Down