JavaThreadPoolExecutor now passes the new queue specs.

Author: jdantonio

lib/concurrent/java_thread_pool_executor.rb

@@ -30,6 +30,8 @@ class JavaThreadPoolExecutor
 
       attr_reader :max_queue
 
+      attr_reader :overflow_policy
+
       # Create a new thread pool.
       #
       # @see http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ThreadPoolExecutor.html
@@ -38,23 +40,23 @@ def initialize(opts = {})
         @max_length = opts.fetch(:max_threads, DEFAULT_MAX_POOL_SIZE).to_i
         idletime = opts.fetch(:idletime, DEFAULT_THREAD_IDLETIMEOUT).to_i
         @max_queue = opts.fetch(:max_queue, DEFAULT_MAX_QUEUE_SIZE).to_i
-        overflow_policy = opts.fetch(:overflow_policy, :abort)
+        @overflow_policy = opts.fetch(:overflow_policy, :abort)
 
         raise ArgumentError.new('max_threads must be greater than zero') if @max_length <= 0
         raise ArgumentError.new("#{overflow_policy} is not a valid overflow policy") unless OVERFLOW_POLICIES.keys.include?(overflow_policy)
 
-        if min_length == 0 && max_queue == 0
+        if min_length == 0 && @max_queue == 0
           queue = java.util.concurrent.SynchronousQueue.new
-        elsif max_queue == 0
+        elsif @max_queue == 0
           queue = java.util.concurrent.LinkedBlockingQueue.new
         else
-          queue = java.util.concurrent.LinkedBlockingQueue.new(max_queue)
+          queue = java.util.concurrent.LinkedBlockingQueue.new(@max_queue)
         end
 
         @executor = java.util.concurrent.ThreadPoolExecutor.new(
           min_length, @max_length,
           idletime, java.util.concurrent.TimeUnit::SECONDS,
-          queue, OVERFLOW_POLICIES[overflow_policy].new)
+          queue, OVERFLOW_POLICIES[@overflow_policy].new)
       end
 
       def min_length
@@ -91,7 +93,7 @@ def queue_length
       end
 
       def remaining_capacity
-        @executor.getQueue.remainingCapacity
+        @max_queue == 0 ? -1 : @executor.getQueue.remainingCapacity
       end
 
       # Is the thread pool running?
@@ -157,6 +159,7 @@ def <<(task)
       # thread pool is not running.
       def shutdown
         @executor.shutdown
+        @executor.getQueue.clear
         return nil
       end
 
@@ -166,6 +169,7 @@ def shutdown
       # not running.
       def kill
         @executor.shutdownNow
+        @executor.getQueue.clear
         return nil
       end