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?