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.
ensure_threads_running!
1 parent 95ea335 commit 2205415Copy full SHA for 2205415
lib/kafka/async_producer.rb
@@ -155,11 +155,8 @@ def ensure_threads_running!
155
return if worker_thread_alive? && timer_thread_alive?
156
157
@thread_mutex.synchronize do
158
- @worker_thread = nil unless worker_thread_alive?
159
- @worker_thread ||= Thread.new { @worker.run }
160
-
161
- @timer_thread = nil unless timer_thread_alive?
162
- @timer_thread ||= Thread.new { @timer.run }
+ @worker_thread = Thread.new { @worker.run } unless worker_thread_alive?
+ @timer_thread = Thread.new { @timer.run } unless timer_thread_alive?
163
end
164
165
0 commit comments