concurrency - Erlang 并发编程

Question

编写一个不带参数的名为calculator 的Erlang 函数。该函数在进程中运行时应该等待接收消息。如果消息是四项元组的形式：{ Pid, Operand, X, Y }，请执行以下操作：

• 如果 Operand 是 add，则向 Pid 发送一条消息，其中包含 X 和 Y 相加的结果。
• 如果操作数是减法，则向 Pid 发送一条消息，其中包含从 X 中减去 Y 的结果。
• 如果操作数是乘法，则向 Pid 发送一条消息，其中包含 X 和 Y 相乘的结果。
• 如果操作数是除数，则向 Pid 发送一条消息，其中包含 X 除以 Y 的结果。

然后，重新运行该函数。

• 如果消息是元组的形式，有两个项目：{ Pid, terminate }，然后向完成的 Pid 发送消息。不要重新运行该函数。

• 如果消息是任何其他形式，请忽略它并重新运行该函数。

我的代码：

calculate() ->
  receive
    {Pid, Operand, X, Y} 
      if 
         Operand == "add" -> Pid ! X+Y
         Operand == "substract" -> Pid ! Y - X
         Operand == "multiply" -> Pid ! X*Y
         Operand == "divide" -> Pid ! X/Y
    {Pid, terminate} -> Pid ! "done"
    _ -> calculate();
  end.

有人可以帮我解决这个问题吗？

标签： concurrencyerlang

Answer 1

您的代码无法编译，您应该先看看基本的 erlang 语法。

我给你一些线索：

您不应该使用该if语句来解决您的问题，而是使用模式匹配，例如

receive
    {From,add,X,Y} ->
        From ! X+Y,
        calculate();
    {From,sub,X,Y} -> 
    ...

通常，为此目的，使用 atom likeadd而不是 string like"add"

您应该有一个功能可以calculate/0在单独的进程中启动该功能：

start() ->
    spawn(fun() -> calculate() end).