写作二郎

Question

“二郎编程软件的并行世界”并行TCP服务器说写一个并行TCP服务器这样做：

start_parallel_server() -> 
    {ok, Listen} = gen_tcp:listen(...), 
    spawn(fun() -> par_connect(Listen) end). 

par_connect(Listen) -> 
    {ok, Socket} = gen_tcp:accept(Listen), 
    spawn(fun() -> par_connect(Listen) end), 
    loop(Socket). 

loop(...) -> %% handle request here 

当start_parallel_server完成其工作，将关闭监听套接字。我们是不是应该在末尾加上timer:sleep(infinity)这样的东西？

Answer 1

如果您从shell运行start_parallel_server()，shell进程将拥有侦听套接字，因此只要该shell进程处于活动状态，它就会保持活动状态。请注意，shell进程在异常时死亡，并且新的shell进程重新生成......可能导致混淆。

但是，如果你产生一个新的进程，依次调用start_parallel_server()函数，您将需要在该产生的进程中进行休眠以保持活跃状态​​。

Answer 2

此外，对于真实世界的应用https://github.com/extend/ranch更合适。