src/code/2/pmap.exs


1
2
3
4
5
6
7
8
9

defmodule MyMap do
  def pmap(collection, f) do
    collection |>
    Enum.map(&(Task.async(fn -> f.(&1) end))) |>
    Enum.map(&Task.await/1)
  end
end

MyMap.pmap(1..10_000, &(&1 * &1)) |> IO.inspect