make sure ThreadedPool keeps consuming even with a failing job

Author: Aaron Patterson and Terence Lee

test/threaded_pool_test.rb

@@ -16,6 +16,12 @@ def run
       end
     end
 
+    class FailingJob
+      def run
+        raise 'fuuu'
+      end
+    end
+
     before do
       @write  = Queue.new(:foo)
       @read  = Queue.new(:foo, Resque.pool)
@@ -32,7 +38,15 @@ def run
     end
 
     it "recovers from blowed-up jobs" do
-      skip
+      Resque.consumer_timeout = 1
+      @tp = ThreadedPool.new(@read, 1)
+      @write << RaiseJob.new
+      @write << Actionable.new
+
+      @tp.start
+      sleep 1
+      @tp.stop
+      assert @write.empty?
     end
 
   end