class Concurrent::RubyThreadPoolExecutor

def ns_reset_if_forked
  if $$ != @ruby_pid
    @queue.clear
    @ready.clear
    @pool.clear
    @scheduled_task_count = 0
    @completed_task_count = 0
    @largest_length       = 0
    @workers_counter      = 0
    @ruby_pid             = $$
  end
end