【发布时间】:2015-06-12 14:03:14
【问题描述】:
写了一些小实验来熟悉这门语言,但遇到了一个我猜是初级的问题。
我有一个简单的主管,有 3 个简单的工人:
def init do
Supervisor.start_link(
[
worker(__MODULE__, [:"process-1"], [function: :test, id: :"p-1"]),
worker(__MODULE__, [:"process-2"], [function: :test, id: :"p-2"]),
worker(__MODULE__, [:"process-3"], [function: :test, id: :"p-3"])
],
strategy: :one_for_one
)
end
":test" 看起来像这样:
def test(name) do
flag(:trap_exit, true)
IO.puts "Testing: #{name} == #{inspect self}"
register(self, name)
receive do
{ :death } ->
IO.puts("I WOZ MURDERED!")
exit(self, "Ex process...")
{ :life } ->
IO.puts("#{inspect self} is listening...")
__MODULE__.test(name)
{ :EXIT, pid, reason } ->
IO.puts "REASON: #{inspect reason} - PROCESS: #{inspect pid}"
end
end
这会编译,但它只会产生一个进程,并挂起/阻塞 iex。
相比之下,当我使用简单的“spawn_link”进程链时,所有三个(或多个)进程同时启动并将控制权返回给 iex shell,以便我可以从命令行发送注册进程消息。
目前,我的意图是创建一个 OTP 主管,运行并注册三个(或多个)工作进程并将它们附加到主管,发送一个简单的消息来杀死给定的工作,然后让主管重新启动它。
我做错了什么?
【问题讨论】:
标签: concurrency functional-programming erlang elixir erlang-otp