避免竞争条件

Question

以下代码 sn-p 取自 Erlang 编程的 Francesco Cesarini 和 Simon Thompson 的书的第 112 页，作为 Erlang 中可能的竞争条件的说明。

start() -> 
  case whereis(db_server) of
    undefined -> 
      Pid = spawn(db_server, init, []), 
      register(db_server, Pid), 
      {ok, Pid};
    Pid when is_pid(Pid) ->
      {error, already_started}
  end.

在不逐字复制细节的情况下，作者解释说，如果两个进程同时执行 start()，那么运行“未定义”部分的进程 1 可能无法完成，因为进程 2 会导致它被抢占。然后进程 2 将运行“未定义”部分以完成。现在，当进程 1 恢复时，db_server 已经被进程 2 注册，导致其对 register() 的调用引发运行时错误。我希望你能明白我的意思，因为我不想盗用这本书的文字。

我的问题是，当两个进程同时执行 start() 时，如何对上述 exact 功能进行编码以避免潜在的竞争条件？

Answer 1

这通常通过让生成的进程注册自己的名称来解决，然后将响应发送回其父进程，告知父进程是否成功。

start() ->
   Pid = spawn(db_server, init, [self()]),
   receive {Pid, StartResult} ->
       StartResult
   end.

init(Parent) ->
    try register(db_server, self()) of
        true ->
            Parent ! {ok, started},
            real_init()
    catch error:_ ->
        Parent ! {error, already_started}
    end.

（可能无法编译或工作。在此处输入但未检查。:)）

您可以在 gen.erl 中找到一个精心实现的版本。实际上，在实际代码中，您只需使用 OTP 行为来重用该版本。

Answer 2

您可以使用gen_server 来序列化请求。

Answer 3

您要启动多少台服务器？您最初的问题暗示一个，而对@cthulahoops 的评论说两个，一个服务器和一个备份。对于两台服务器，您可以尝试以下操作：

start() ->
    case whereis(db_server) of
        undefined ->
            Spid = spawn(db_server, init, []),
            %% In race condition there can be only one that succeeds to register
            case catch register(db_server, Spid) of
                true -> {ok,Spid};             %We are it
                {error,_} ->                   %Server registered, register as backup
                    register(db_server_backup, Spid),
                    {ok,Spid}
            end;
        _ ->                                   %Server registered, start backup
            Bpid = spawn(db_server, init, []),
            register(db_server_backup, Bpid),
            {ok,Bpid}
    end.

我还没有运行它。