Merge pull request #138 from ruby-concurrency/wait_for_termination

JavaExecutor#wait_for_termination now honors a nil timeout (wait forever).

Author: jdantonio

lib/concurrent/executor/executor.rb

@@ -250,8 +250,13 @@ def shutdown?
       end
 
       # @!macro executor_method_wait_for_termination
-      def wait_for_termination(timeout)
-        @executor.awaitTermination(1000 * timeout, java.util.concurrent.TimeUnit::MILLISECONDS)
+      def wait_for_termination(timeout = nil)
+        if timeout.nil?
+          ok = @executor.awaitTermination(60, java.util.concurrent.TimeUnit::SECONDS) until ok
+          true
+        else
+          @executor.awaitTermination(1000 * timeout, java.util.concurrent.TimeUnit::MILLISECONDS)
+        end
       end
 
       # @!macro executor_method_shutdown

spec/concurrent/executor/executor_service_shared.rb

@@ -178,5 +178,12 @@
         expect(subject.wait_for_termination(0)).to be_falsey
       end
     end
+
+    it 'waits forever when no timeout value is given' do
+      subject.post{ sleep(0.5) }
+      sleep(0.1)
+      subject.shutdown
+      expect(subject.wait_for_termination).to be_truthy
+    end
   end
 end