Add bench directory

Author: José Valim

bench/erlang.exs

@@ -0,0 +1,28 @@
+# MIX_ENV=bench mix run bench/erlang.exs
+# TASKS=8 MIX_ENV=bench mix run bench/erlang.exs
+
+Code.require_file "shared.exs", __DIR__
+
+defmodule ErlangRegistry do
+  def whereis_name(name) do
+    :erlang.whereis(name)
+  end
+
+  def register_name(name, pid) when pid == self() do
+    :erlang.register(name, pid)
+    :yes
+  end
+end
+
+tasks = String.to_integer System.get_env("TASKS") || "1"
+
+names =
+  for task <- 1..tasks do
+    for i <- 1..10000, do: :"name-#{task}-#{i}"
+  end
+
+:timer.tc(fn ->
+  names
+  |> Enum.map(&Task.async(Shared, :register, [&1]))
+  |> Enum.each(&Task.await(&1, :infinity))
+end) |> IO.inspect

bench/gproc.exs

@@ -0,0 +1,18 @@
+# MIX_ENV=bench mix run bench/erlang.exs
+# TASKS=8 MIX_ENV=bench mix run bench/erlang.exs
+
+Code.require_file "shared.exs", __DIR__
+Application.ensure_all_started(:gproc)
+
+tasks = String.to_integer System.get_env("TASKS") || "1"
+
+names =
+  for task <- 1..tasks do
+    for i <- 1..10000, do: {:via, :gproc, {:n, :l, {task, i}}}
+  end
+
+:timer.tc(fn ->
+  names
+  |> Enum.map(&Task.async(Shared, :register, [&1]))
+  |> Enum.each(&Task.await(&1, :infinity))
+end) |> IO.inspect

bench/registry.exs

@@ -0,0 +1,20 @@
+# MIX_ENV=bench mix run bench/erlang.exs
+# TASKS=8 MIX_ENV=bench mix run bench/erlang.exs
+# PARTITIONS=8 TASKS=8 MIX_ENV=bench mix run bench/erlang.exs
+
+Code.require_file "shared.exs", __DIR__
+partitions = String.to_integer System.get_env("PARTITIONS") || "1"
+Registry.start_link(:unique, Registry, partitions: partitions)
+
+tasks = String.to_integer System.get_env("TASKS") || "1"
+
+names =
+  for task <- 1..tasks do
+    for i <- 1..10000, do: {:via, Registry, {Registry, {task, i}}}
+  end
+
+:timer.tc(fn ->
+  names
+  |> Enum.map(&Task.async(Shared, :register, [&1]))
+  |> Enum.each(&Task.await(&1, :infinity))
+end) |> IO.inspect

bench/shared.exs

@@ -0,0 +1,10 @@
+defmodule Shared do
+  @compile :inline_list_funcs
+
+  def register(names) do
+    :lists.foreach(fn name ->
+      Agent.start_link(fn -> [] end, name: name)
+    end, names)
+    :ok
+  end
+end

mix.exs

@@ -33,6 +33,7 @@ defmodule Registry.Mixfile do
   #
   # Type "mix help deps" for more examples and options
   defp deps do
-    [{:ex_doc, "~> 0.14", only: :docs}]
+    [{:ex_doc, "~> 0.14", only: :docs},
+     {:gproc, "~> 0.6", only: :bench}]
   end
 end

mix.lock

@@ -1,2 +1,3 @@
 %{"earmark": {:hex, :earmark, "1.0.2", "a0b0904d74ecc14da8bd2e6e0248e1a409a2bc91aade75fcf428125603de3853", [:mix], []},
-  "ex_doc": {:hex, :ex_doc, "0.14.3", "e61cec6cf9731d7d23d254266ab06ac1decbb7651c3d1568402ec535d387b6f7", [:mix], [{:earmark, "~> 1.0", [hex: :earmark, optional: false]}]}}
+  "ex_doc": {:hex, :ex_doc, "0.14.3", "e61cec6cf9731d7d23d254266ab06ac1decbb7651c3d1568402ec535d387b6f7", [:mix], [{:earmark, "~> 1.0", [hex: :earmark, optional: false]}]},
+  "gproc": {:hex, :gproc, "0.6.1", "4579663e5677970758a05d8f65d13c3e9814ec707ad51d8dcef7294eda1a730c", [:rebar3], []}}