From 2f25a354b22a0b3a168a81b3bb90546de511f556 Mon Sep 17 00:00:00 2001
From: Joshua Young <djry1999@gmail.com>
Date: Wed, 27 Aug 2025 15:38:15 +1000
Subject: [PATCH] Keep worker threads running until exit

---
 lib/segment/analytics/worker.rb | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/lib/segment/analytics/worker.rb b/lib/segment/analytics/worker.rb
index 6a7d68e..acb1e1b 100644
--- a/lib/segment/analytics/worker.rb
+++ b/lib/segment/analytics/worker.rb
@@ -38,7 +38,10 @@ def initialize(queue, write_key, options = {})
       #
       def run
         until Thread.current[:should_exit]
-          return if @queue.empty?
+          if @queue.empty?
+            sleep(0.1)
+            next
+          end
 
           @lock.synchronize do
             consume_message_from_queue! until @batch.full? || @queue.empty?