class Parallel::JobFactory

def queue_wrapper(array)
  array.respond_to?(:num_waiting) && array.respond_to?(:pop) && -> { array.pop(false) }
end