Paralelle map

pm.rb

pm=ParalleleMap.new(
       :nbThread   => 5, 
       :generator  => proc { |res| 
              rfind("/" , ".rb"  ) { |file| res << file ; } 
       },
       :mapper     => proc { |out,in_file_name|  
              selectLine(out,query,in_file_name) 
       },
       :reducer    =>proc { |rr| reduce(rr) },
       :debug => (debug!=nil)
)
#.... here can do other things
result=pm.get_result()