class Parallel::Worker

when running in isolation mode, so we have to check if it is closed before closing
might be passed to started_processes and simultaneously closed by another thread

def close_pipes
  read.close unless read.closed?
  write.close unless write.closed?
end