concurrency - Erlang ETS 插入/2 错误

Question

我正在尝试创建一个可以访问 ETS 模块的简单 Erlang 进程。

我的源代码包括：

1. 进程创建：

   start_message_channel() ->
       Table = ets:new(messages, [ordered_set, named_table]),
       Channel = spawn(?MODULE, channel, []),
       {Channel, {table, Table}}.
   

2. 流程逻辑：

   channel() ->
       receive
           {Sender, {send_message, {Message, Table}}} ->
               ets:insert(Table, {message, Message}),
               Sender ! {self(), {status, success}};
           {Sender, {receive_message, Table}} ->
               {message, Message} = ets:first(Table),
               Sender ! {self(), {status, {success, Message}}};
           _ ->
               throw(incorrect_protocol_exception)
   end.
   

3. 与进程的通信

   send_message_to_message_channel({Channel, {table, Table}}, Message) ->
       Channel ! {self(), {send_message, {Message, Table}}},
       receive
           {Channel, {status, success}} ->
               io:format("Message sent!~n");
           {Channel, {status, failure}} ->
               io:format("Message failed to send!~n");
           _ ->
               throw(incorrect_protocol_exception)
   end.
   
   receive_message_from_message_channel({Channel, {table, Table}}) ->
       Channel ! {self(), {receive_message, Table}},
       receive
           {Channel, {status, {success, Message}}} ->
               io:format(Message);
           {Channel, {status, failure}} ->
               io:format("Message failed to receive!~n");
           _ ->
               throw(incorrect_protocol_exception)
   end.
   

在 Erlang 终端中执行函数调用时，出现错误：

    1> cd("C:/Users/dauma").                    
    C:/Users/dauma
    ok
    2> c(message_channel).
    {ok,message_channel}
    3> Object = message_channel:start_message_channel().
    {<0.59.0>,{table,messages}}
    4> message_channel:send_message_to_message_channel(Object, "Hello World!").

    =ERROR REPORT==== 19-May-2016::11:09:27 ===
    Error in process <0.59.0> with exit value:
    {badarg,[{ets,insert,[messages,"Hello World!"],[]},
        {message_channel,channel,0,
            [{file,"message_channel.erl"},{line,35}]}]}

谁能告诉我，问题可能出在哪里？

Answer 1

ETS 表由 Erlang 进程拥有，并具有访问控制。默认情况下，该表protected只能由拥有它的进程写入并且只能由拥有它的进程写入，尽管它可以从其他进程中读取。

如果您想从不同的进程读取和写入，请使用public.

Table = ets:new(messages, [ordered_set, named_table, public])

您也可以使用private，这意味着只有拥有的进程可以读取和写入。

根据文档：

• public任何进程都可以读取或写入表。
• protected所有者进程可以读取和写入表。其他进程只能读取该表。这是访问权限的默认设置。
• private只有所有者进程可以读取或写入表。

在您的示例中，您在一个进程（调用的那个start_message_channel）中创建表，然后尝试ets:insert从另一个进程调用：spawn(?MODULE, channel, [])创建一个新进程，并将channel其作为其入口点。

因为您的表未标记为，所以来自其他进程public的调用失败并显示。ets:insertbadarg

根据文档，再次：

badarg通常，如果任何参数格式错误、表标识符无效或由于表访问权限（protected或）而拒绝操作，则以下函数将退出private。

---

旁注：如果你使用named_table，返回的值ets:new 是表名，所以你可以这样做：

-define(TABLE, messages).

% later...
?TABLE = ets:new(?TABLE, [named_table, ordered_set, protected])

...并且您不需要将返回的值存储在 state 中。