Erlang中有没有类似于unix下的IO多路复用机制

Question

一个unix程序希望从多个文件描述符中读取数据，直接使用read系统调用去处理有可能会阻塞在一个文件描述符上，而不能处理其他的文件描述符，因此系统提供了select系统调用对多个文件描述符进行监测。

在erlang系统中也存在类似的问题，如果process既需要读文件又需要接收消息，该如何处理了？当然最简单的方法是创建一个新的process，原有的process执行IO阻塞操作，新的process执行接收消息的阻塞操作。不知道Erlang中有没有类似于unix下的IO多路复用机制，使用一个process就可以监测两个信号源。

具体以下面的chat server例子来说，程序中的main process执行accept操作，client_manager process执行client集合的管理操作，我希望main process能够和client manager process合并，这样可以简化程序的逻辑。

多谢回答。

2. -module(basicchat).
3. -export([listen/1]).
5. %% 侦听socket的 TCP 选项。第一个 list 元语
6. %% 表示我们想接收数据的是字节列表(如
7. %% 字符串)，而不是二进制的对象。
8. %% 其他的参数请参考 Erlang 文档。
10. -define(TCP_OPTIONS,[list, {packet, 0}, {active, false}, {reuseaddr, true}]).
12. %% 侦听指定的端口，接受第一个连接，
13. %% 然后启动 echo 循环。同时要启动 client_manager，
14. %% 这个是服务器的入口点。
16. listen(Port) ->
17.     Pid = spawn(fun() -> manage_clients([]) end),
18.     register(client_manager, Pid),
19.     {ok, LSocket} = gen_tcp:listen(Port, ?TCP_OPTIONS),
20.     do_accept(LSocket).
22. %% 接受以后创建处理过程，
23. %% 末尾调用 do_accept 再次进入侦听
24. %% 还要通知 client_manager 有新的连接要加入
26. do_accept(LSocket) ->
27.     {ok, Socket} = gen_tcp:accept(LSocket),
28.     spawn(fun() -> handle_client(Socket) end),
29.     client_manager ! {connect, Socket},
30.     do_accept(LSocket).
32. %% handle_client/1 替换掉 do_echo/1 ，因为现在所有事情都要
33. %% 通过 client_manager 完成。断开时通知 client_manager
34. %% socket 已经关闭，数据就当是发送完成了。
36. handle_client(Socket) ->
37.     case gen_tcp:recv(Socket, 0) of
38.         {ok, Data} ->
39.             client_manager ! {data, Data},
40.             handle_client(Socket);
41.         {error, closed} ->
42.             client_manager ! {disconnect, Socket}
43.     end.
45. %% 维护 socket 列表，处理连接和断开消息，
46. %% 并互相传递数据
48. manage_clients(Sockets) ->
49.     receive
50.         {connect, Socket} ->
51.             io:fwrite("Socket connected: ~w~n", [Socket]),
52.             NewSockets = [Socket | Sockets];
53.         {disconnect, Socket} ->
54.             io:fwrite("Socket disconnected: ~w~n", [Socket]),
55.             NewSockets = lists:delete(Socket, Sockets);
56.         {data, Data} ->
57.             send_data(Sockets, Data),
58.             NewSockets = Sockets
59.     end,
60.     manage_clients(NewSockets).
62. %% 给列表中的所有 socket 发消息。通过 lists:foreach/2 遍历
63. %% 列表中的每个 socket,再调用 gen_tcp:send 来发送数据
65. send_data(Sockets, Data) ->
66.     SendData = fun(Socket) ->
67.                        gen_tcp:send(Socket, Data)
68.                end,
69.     lists:foreach(SendData, Sockets).

复制代码

Answer 1

小弟初学erlang，?TCP_OPTIONS之前的?代表什么意思？