-
Notifications
You must be signed in to change notification settings - Fork 0
/
ticker.exs
58 lines (47 loc) · 1.03 KB
/
ticker.exs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
defmodule Tick do
@interval 2000
@name :ticker
def start do
pid = spawn(__MODULE__, :tick, [[]])
:global.register_name(@name, pid)
end
def register(client_pid) do
send :global.whereis_name(@name), { :register, client_pid }
end
def generator([], n) do
receive do
{ :register, pid } ->
IO.puts "Registering #{inspect pid}"
generator([pid], n)
after
@interval ->
IO.puts "tick"
generator([], n + 1)
end
end
def generator(clients, n) do
receive do
{ :register, pid } ->
IO.puts "Registering #{inspect pid}"
generator(clients ++ [pid], n)
after
@interval ->
IO.puts "tick"
send Enum.at(clients, rem(n, length(clients))), { :tick }
generator(clients, n + 1)
end
end
end
defmodule Client do
def start do
pid = spawn(__MODULE__, :receiver, [])
Tick.register(pid)
end
def receiver do
receive do
{ :tick } ->
IO.puts "tock in client"
receiver
end
end
end