1 files changed, 4 insertions, 0 deletions
diff --git a/lib/thread.rb b/lib/thread.rb
index ec75144374..4e6d765686 100644
--- a/lib/thread.rb
+++ b/lib/thread.rb
@@ -144,6 +144,10 @@ class Queue
     @que.length == 0
   end
 
+  def clear
+    @que.replace([])
+  end
+
   def length
     @que.length
   end