#9 練習問題6クリア

Author: MrBearing

lib/ch14/WorkingWithMultipleProcess06.ex

@@ -1,29 +1,39 @@
-defmodule WWMP3 do
-  import :timer, only: [sleep: 1 ]
-
-  def child_func(pid, message) do
-    send pid , message
-    raise "Some error occur"
-  end
-
-  def receive_func() do
-    receive do msg -> IO.puts(msg) end
-    receive_func()
-  end
-
-  def parent_func() do
-    spawn_link(WWMP3, :child_func, [self(), "This is message"])
-    sleep 500
-    receive_func()
-  end
-
-
-  def run() do
-    parent_func()
+defmodule Parallel do
+  def pmap(collection, fun)do
+    me = self()
+    IO.puts(" me :#{inspect me}")
+    collection
+    |> Enum.map(fn (elem) ->
+      IO.puts("enume: #{inspect self()}")
+      spawn_link fn ->
+        IO.puts("spawn: #{inspect self()}")
+        (send me, {self(), fun.(elem)})
+      end
+    end)
+    |> Enum.map(fn (pid) ->
+      receive do{^pid, result} -> result end
+    end)
   end
 end
 
-WWMP3.run()
-
 
-# 例外が発生し、子プロセスからのメッセージが受信できない
+"""
+selfのスコープが異なるので、メインのプロセスのpidを別途取得する必要がある
+
+iex(1)> c("WorkingWithMultipleProcess06.ex")
+[Parallel]
+iex(2)> Parallel.pmap 1..5 ,&(&1 * &1)
+ me :#PID<0.105.0>
+enume: #PID<0.105.0>
+enume: #PID<0.105.0>
+spawn: #PID<0.177.0>
+enume: #PID<0.105.0>
+spawn: #PID<0.178.0>
+enume: #PID<0.105.0>
+spawn: #PID<0.179.0>
+enume: #PID<0.105.0>
+spawn: #PID<0.180.0>
+spawn: #PID<0.181.0>
+[1, 4, 9, 16, 25]
+
+"""

memorandum/ch14/pmap.exs

@@ -10,3 +10,9 @@ defmodule Parallel do
     end)
   end
 end
+
+
+"""
+
+
+"""