fishcakez’s gists

fishcakez / async_query.ex

Created October 17, 2015 16:22 — forked from gjaldon/async_query.ex

	def async_query(pid, statement, params) do
	message = {:query, statement, params}
	process = GenServer.whereis(pid)
	monitor = Process.monitor(process)
	from = {self(), monitor}

	:ok = Connection.cast(pid, {message, from})
	%Task{ref: monitor}
	end

fishcakez / kv_server.ex

Last active August 29, 2015 14:22 — forked from smanolloff/kv_server.ex

	defmodule KVServer do
	use Application

	def start(_type, _args) do
	import Supervisor.Spec

	children = [
	supervisor(Task.Supervisor, [[name: KVServer.TaskSupervisor]]),
	worker(Task, [KVServer, :accept, [4040]])
	]

fishcakez / basic_bench.exs

Last active August 29, 2015 14:20 — forked from jeffweiss/basic_bench.exs

fishcakez / gist:ae40d2667ea9d414caf3

Last active August 29, 2015 14:19 — forked from pmarreck/default_args_fun.exs


	def concurrent_factorial(range, worker_pool_by_nodenames \\ worker_pool_by_nodenames)

	def concurrent_factorial(%Range{first: start, last: finish}, worker_pool_by_nodenames) do
	pmap(split_range_of_numbers(start..finish), fn(range) -> range \|> Enum.reduce(&(&1*&2)) end, worker_pool_by_nodenames) \|>
	Enum.reduce(&(&1*&2))
	end

	def concurrent_factorial(n, worker_pool_by_nodenames) when is_integer(n) and n > 0 do
	concurrent_factorial(1..n, worker_pool_by_nodenames)

fishcakez / gist:abca4a9fc5f3ebfece99

Last active August 29, 2015 14:04 — forked from alco/match.exs

	File.read("match.exs") \|> (fn({:ok, bin}) -> bin end).() \|> String.length
	#=> 156

	s = """
	id;name;value
	1;foo;hi
	2;bar;bye
	"""

	s

fishcakez / exercise.exs

Last active August 29, 2015 14:02 — forked from josevalim/exercise.exs

fishcakez / gist:a86a65db8303d307b658

Last active August 29, 2015 14:02 — forked from josevalim/gist:f0d9025bb3f5a580aee6

	=ERROR REPORT==== 12-Jun-2014::15:23:03 ===
	** Task <0.38.0> terminating │
	** Started by local_name_or_pid │
	** When Function == #Fun<erlang.hd.1> │
	** Arguments == [[]]
	** Reason for termination ==
	** {badarg,[{erlang,hd,[[]],[]},
	{'Elixir.Agent.Server',handle_call,3,
	[{file,"lib/agent/server.ex"},{line,11}]},
	{gen_server,handle_msg,5,[{file,"gen_server.erl"},{line,580}]},

fishcakez / fib_with_agents.exs

Last active August 29, 2015 14:01 — forked from josevalim/fib_with_agents.exs

	defmodule FibAgent do
	def start_link do
	cache = Enum.into([{0, 0}, {1, 1}], HashDict.new)
	Agent.start_link(fn -> cache end)
	end

	def fib(pid, n) when n >= 0 do
	Agent.get_and_update(pid, &do_fib(&1, n))
	end

fishcakez / my_receive.exs

Created March 12, 2014 17:30 — forked from josevalim/my_receive.exs

	defmodule MyReceive do
	defmacro my_receive(do: clauses) do
	extra = quote do
	other -> IO.puts "got #{inspect other}"
	end

	quote do
	receive do: unquote(clauses ++ extra)
	end
	end

fishcakez / recypc_session.erl

Last active December 18, 2015 15:29 — forked from dvv/recypc_session.erl

	-module(pecypc_session).
	-author('Vladimir Dronnikov <[email protected]>').

	%% -----------------------------------------------------------------------------
	%% API exports
	%% -----------------------------------------------------------------------------

	-export([
	add/1,
	add/2,

James Fish fishcakez