在 erlang 中避免竞争条件

Question

这是避免竞争条件的方法吗？

-module(b).
-export([my_spawn/1]).



my_spawn(Func) ->
    Pid = spawn(listener()),
    Pid ! {self(), spawn, Func},
    receive 
        {From, Desired_Pid} -> Desired_Pid
    end.




listener() ->

    receive 
        {From, spawn, Func} -> 
        {Pid,Ref} = spawn_monitor(Func),
        From ! {self(), Pid},
        receive 
            {'DOWN',Ref, process, _, _} -> io:format("I lived for [calculated how long i lived]")
        end
    end.

我想在这里实现的是

A = spawn(proc),
monitor(process,A).

但是 A 可能会在第二行执行之前死掉。

Answer 1

如果您生成了一个进程并且它在您创建监视器之前终止，您仍然会收到DOWN 消息：

1> Pid = spawn(erlang,now,[]).
<0.35.0>
2> is_process_alive(Pid).
false
3> monitor(process, Pid).
#Ref<0.0.0.86>
4> flush().
Shell got {'DOWN',#Ref<0.0.0.86>,process,<0.35.0>,noproc}

正如这个 shell 会话所示，我们首先故意生成一个短暂的进程，然后使用is_process_alive 来验证它是否已经死亡。然后，我们为该进程创建一个监视器，然后我们刷新 shell 的消息队列，并看到它确实收到了已死进程的 DOWN 消息。