MapReduceã·ãªã¼ãºã®ç¬¬5å¼¾ã第4å¼¾ã¾ã§ã¯ãã¡ã â Scala / Erlang / Go / F# The Omnibus Concurrency Libraryã¨ããã®ã使ã£ã¦ã¿ããScalaã®ã¢ã¯ã¿ã¼ã¨åãæãã require 'concurrent/actors' include Concurrent::Actors KeyValue = Case.new :key, :value Exit = Case.new :reply_to Complete = Case.new :actor, :result def log *args puts *args end class MapReduce # ç¹°ãè¿ãå¦çãããã¢ã¯ã¿ã¼ãä½ã def loop_receive acc0 = nil, &block Actor.spawn do acc = acc0 loop do Ac
{{#tags}}- {{label}}
{{/tags}}