Sergey Kuznetsov cr0t

GenServer.reply/2

Check the other two files in this gist.

In the common.exs we show a standard approach (by the book) to handle incoming requests via handle_call/3 and {:reply, ...} return values. It blocks processing of all the coming requests until the one that is handled finished.

In contrast, in the reply.exs we leverage power of Task.async/1, GenServer.reply/2, and {:noreply, ...} return values. It allows our GenServer process incoming requests in parallel. Then the processing finished, we send results back to the original client (from pid).

Warning

Be careful, as this approach can lead to uncontrollable load to our GenServer.

	defmodule RegistryEts do
	use GenServer

	def register(key, pid \\ self()),
	do: GenServer.call(__MODULE__, {:register, key, pid})

	def whereis(key) do
	case :ets.lookup(__MODULE__, key) do
	[{^key, pid}] -> pid
	_ -> nil

	Mix.install([:benchee])

	defmodule ResistorColor do
	@color_map %{
	black: 0,
	brown: 1,
	red: 2,
	orange: 3,
	yellow: 4,
	green: 5,

	Mix.install([:benchee])

	# Compare access times to the elements in a Tuple, a Map, or a List containers.
	#
	# At first, we generate some input that is being used in the access_* functions:
	# they go over each element and check if it is what we put there. One by one.

	defmodule Accessor do
	@elements_n 10_000

	Mix.install([:benchee])

	defmodule LuhnChecksum do
	defguard is_even(x) when rem(x, 2) == 0

	def with_reverse(digits) do
	digits
	\|> Enum.reverse()
	\|> Enum.with_index(1)
	\|> Enum.map(fn

	Mix.install([:benchee])

	defmodule StringPerf do
	def concat([]), do: ""
	def concat([head \| tail]), do: head <> concat(tail)

	def interpol([]), do: ""
	def interpol([head \| tail]), do: "#{head}#{interpol(tail)}"

	def joiner(input), do: Enum.join(input, "")

	defmodule Clusty.Application do
	use Application

	@topologies local_epmd: [strategy: Cluster.Strategy.LocalEpmd]

	@impl true
	def start(_type, _args) do
	children = [
	{Cluster.Supervisor, [@topologies, [name: ClusterSupervisor]]},
	Pidgy

	Mix.install([:benchee])

	defmodule Proteins do
	@stop "STOP"
	@err_msg "invalid codon"

	@codons %{
	"UGU" => "Cysteine",
	"UGG" => "Tryptophan",
	"UUU" => "Phenylalanine",

	name: Elixir CI

	on:
	push:
	branches: ["master"]
	pull_request:
	branches: ["master"]

	env:
	MIX_ENV: test

	Mix.install([
	{:benchee, "~> 1.0"}
	])

	defmodule Cruncher do
	def async(n) do
	1..n
	\|> Task.async_stream(&(&1 ** 2))
	\|> Enum.reduce(0, fn {:ok, s}, acc -> s + acc end)
	end