Merge pull request #452 from brandonhilkert/move-completed

Move completed_task_count incrementer after task is successful

Author: jdantonio

lib/concurrent/executor/ruby_thread_pool_executor.rb

@@ -101,6 +101,11 @@ def worker_died(worker)
       synchronize { ns_worker_died worker }
     end
 
+    # @!visibility private
+    def worker_task_completed
+      synchronize { @completed_task_count += 1 }
+    end
+
     private
 
     # @!visibility private
@@ -180,7 +185,6 @@ def ns_assign_worker(*args, &task)
       worker = (@ready.pop if @pool.size >= @min_length) || ns_add_busy_worker
       if worker
         worker << [task, args]
-        @completed_task_count += 1
         true
       else
         false
@@ -327,6 +331,7 @@ def create_worker(queue, pool, idletime)
 
       def run_task(pool, task, args)
         task.call(*args)
+        pool.worker_task_completed
       rescue => ex
         # let it fail
         log DEBUG, ex