为什么这个erlang代码不起作用？

fib(N)-> 
     P1 = spawn(fun concFib:conFib/0), 
     P2 = spawn(fun concFib:conFib/0), 
     X=rpc(P1,N-2),Y=rpc(P2,N-1),X+Y. 

conFib()-> 
     receive 
       {Client,N} -> Client ! regfib(N) 
     end. 

rpc(Pid,Request)-> 
     case erlang:is_process_alive(Pid) of 
       true -> begin 
             Pid ! {self(),Request}, 
             receive 
               {Pid,Respond} -> Respond 
             end 
           end; 
       false -> io:format("~w process is dead.",[Pid]) 
     end. 


regfib(N)-> 
     case N<2 of 
       true -> 1; 
       false -> regfib(N,1,1,1) 
     end. 

regfib(N,N,X,_)-> X ; 
regfib(N,M,X,Y)-> regfib(N,M+1,X+Y,X).

的想法是到FIB（N）处理划分为两个过程中的一个来计算FIB（N-2）和另一种计算。 fib（N-1）同时作为fib（N）= fib（N-1）+ fib（N-2）。当我运行前面的代码时，什么也没有发生，并且光标在有限循环中停止，或者等待没有到达的结果。
plzzz我需要帮助我是一个新的Erlang程序员，在此先感谢:)为什么这个erlang代码不起作用？

来源

2009-11-08 Fuzzix

不知道你的意图是用这段代码，但注意X和Y不是并行计算的。 – Zed 2009-11-08 22:11:48

我想并行计算X和Y，这是我的意图。 – Fuzzix 2009-11-08 22:32:08

现在您的呼叫流程基本上是send-to-1，receive-from-1，send-to-2，recive-from-2，其中receive是您的代码块。您应该将其更改为发送至1，发送至2，接收1，接收2。 – Zed 2009-11-08 22:34:32

在您的conFib中发送一个整数，但在rpc中等待一个元组。应将其更改为：

conFib()-> 
     receive 
       {Client,N} -> Client ! {self(), regfib(N)} 
     end.

您可以通过在接收使用超时与after规避此类情况。

来源

2009-11-08 22:03:14 Zed

Thanks Zed :)，它解决了这个问题，但是代码的逻辑并不如我所期望的那样工作:(。 X = rpc（P1，N-2）和X = rpc（P2，N-1）同时工作第二个等待第一个要完成我想计算fib（N-1）和fib（N-2）在同一时间在不同的过程中的每一个。我wana更多的帮助plz ... – Fuzzix 2009-11-08 22:25:44

为了使计算平行，你可以这样做：

fib(N)-> 
     P1 = spawn(fun test:conFib/0), 
     P2 = spawn(fun test:conFib/0), 
     P1 ! {self(), N - 2}, 
     P2 ! {self(), N - 1}, 
     receive 
     {_, R1} -> R1 
     end, 
     receive 
     {_, R2} -> R2 
     end, 
     R1 + R2.

的重要组成部分，是你在等待的答案之前，同时发送的请求。等待答案的部分当然可以以更美丽的方式完成。

来源

2009-11-08 22:37:29 Rickard

谢谢Rickard：）...我知道了..原谅我，你的答案对我更具体，把Q当成Zed先回答。 – Fuzzix 2009-11-08 22:50:47

为什么这个erlang代码不起作用？

回答

相关问题