I want to communicate with Ruby repeatedly between processes.

require 'thread'
require 'time'
require 'find'

read, write = IO.pipe

# child processing
fork do
  testArray=Array.new
  inArray = {
      —id=>1000,
      —type=>"A"
  }
  testArray <<inArray
  testArray <<inArray

  # Close as it is not read by child process
  read.close
  loop do
      str = Marshall.dump (testArray)
      write.puts str
#      write.close
      sleep5
  end

  write.close
end

# parent process processing
# Close as no parent writes
write.close
Thread.new do
  loop do
    read.read
    result=Marshal.load(message)
  end

end

# Waiting for process processing to end
Process.waitall

read.close
  loop do
      str = Marshall.dump (testArray)
      write.puts str + 'end' ★
      sleep5
  end

loop do
    read.read
    while message=read.gets('end')★
      message.delete('end') ★
      results=Marshal.load(message)
    end
  end