watch a dir for new files and do some work

watch.rb

require 'listen'
require 'rb-fsevent'

LISTEN_PATH = '/tmp/m'

consumer, producer = IO.pipe

Dir["#{LISTEN_PATH}/*"].each {|n| producer.puts n } 

2.times do    
  fork do
    puts "consumer started #{$$}"    
    loop do    
      if IO.select([consumer], nil, nil, 2)  
        path = consumer.gets        
        puts "out[#{$$}]: #{path}"
      end
    end
  end
end

Listen.to(LISTEN_PATH) do |_, added, _|
  added.each{|n| producer.puts n }
end