为什么你可以在 Erlang 中为同一个进程创建多个监视器引用？

Question

这是一个示例跟踪，我可以在同一个 Pid 上调用 erlang:monitor/2：

1> Loop = fun F() -> F() end.
#Fun<erl_eval.30.99386804>
2> Pid = spawn(Loop).
<0.71.0>
3> erlang:monitor(process, Pid).
#Ref<0.2485499597.1470627842.126937>
4> erlang:monitor(process, Pid).
#Ref<0.2485499597.1470627842.126942>
5> erlang:monitor(process, Pid).
#Ref<0.2485499597.1470627842.126947>

指令#4 和#5 返回的表达式与#3 不同，这意味着可以在当前进程和Pid 之间创建多个监视器引用。是否存在您需要或使用多个监视器引用到同一进程的实际案例？

我希望这将返回相同的引用（返回一个新的可能意味着旧的失败/崩溃），遵循与 link/1 相同的逻辑。

Answer 1

假设您使用第三方库来执行此操作（基本上是 OTP *:call/* 函数所做的）：

call(Pid, Request) ->
    call(Pid, Request, ?DEFAULT_TIMEOUT).

call(Pid, Request, Timeout) ->
    MRef = erlang:monitor(process, Pid),
    Pid ! {call, self(), MRef, Request},
    receive
      {answer, MRef, Result} ->
        erlang:demonitor(Mref, [flush]),
        {ok, Result};
      {'DOWN', MRef, _, _, Info} ->
        {error, Info}
    after Timeout ->
        erlang:demonitor(MRef, [flush]),
        {error, timeout}
    end.

然后你在你的代码中使用它来监控相同的进程Pid，然后调用函数call/2,3。

my_fun1(Service) ->
    MRef = erlang:monitor(process, Service),
    ok = check_if_service_runs(MRef),
    my_fun2(Service),
    mind_my_stuf(),
    ok = check_if_service_runs(MRef),
    erlang:demonitor(MRef, [flush]),
    return_some_result().

check_if_service_runs(MRef) ->
    receive
      {'DOWN', MRef, _, _, Info} -> {down, Info}
    after 0 -> ok
    end.

my_fun2(S) -> my_fun3(S).

% and a many layers of other stuff and modules
my_fun3(S) -> call(S, hello).

如果erlang:monitor/2,3 总是返回相同的引用并且erlang:demonitor/1,2 会删除您以前的监视器，那将是多么令人讨厌的惊喜。这将是丑陋和无法解决的错误的来源。你应该开始认为有库，其他进程，你的代码是一个庞大系统的一部分，而 Erlang 是由经过深思熟虑的有经验的人制作的。可维护性是这里的关键。