diff --git a/lib/redic/pool.rb b/lib/redic/pool.rb
index 452c3db..ac0d1f8 100644
--- a/lib/redic/pool.rb
+++ b/lib/redic/pool.rb
@@ -27,9 +27,10 @@ def queue(*args)
 
   def commit
     @pool.with do |client|
-      Thread.current[@id].each do |args|
+      (Thread.current[@id] || []).each do |args|
         client.queue(*args)
       end
+      Thread.current[@id] = [] # clear the thread queue
 
       client.commit
     end