我是Erlang的新手,我正试图让一个Pid向其他几个Pid发送消息。
我有一个函数,它将Pid、字符串(消息)和整数R(半径)作为参数。
broadcast(P, M, R) ->
P ! {self(), friends},
receive
{P, Friends} ->
[F ! {{broadcast, P, M, R}, Friends} || F <- Friends],
ok;
{} ->
end.
我有一个等待接收新消息的侦听器功能:
looper({Name, Friends, Messages}) ->
receive
{From, friends} ->
From ! {self(), Friends},
looper({Name, Friends, Messages});
{{broadcast, ID, M, R}, Friends} ->
% From ! {From, {self(), {ID, M}}},
looper({Name, Friends, [{ID, M} | Messages]});
terminate ->
ok
end.
当我调用功能广播时,我会收到以下消息:
faceinsok:broadcast(Pid, "asd", 1).
** exception error: bad argument
in function faceinsok:'-broadcast/3-lc$^0/1-0-'/5 (faceinsok.erl, line 56)
第56行是
[F ! {{broadcast, P, M, R}, Friends} || F <- Friends],
据我所知,我没有正确传递以下信息:/我做错了什么?
再次。在第55行中,您收到了{P, Friends}
,并假设Friends
是一个列表。但我想不是,因为在第53行你发送的是{self(), friends}
。并且不能在原子friends
上进行列表编译。
如果Friends
实际上是一个列表,则应该添加保护检查。
receive
{P, Friends} when is_list(Friends) ->
[F ! {{broadcast, P, M, R}, Friends} || F <- Friends],
ok;
{} ->
然后检查它是否按照你想象的方式工作。