码迷,mamicode.com
首页 > 其他好文 > 详细

初次使用erlang的concurrent

时间:2014-05-08 07:01:11      阅读:359      评论:0      收藏:0      [点我收藏+]

标签:style   blog   class   code   java   tar   

如果不是它骇人听闻的并行性能,几乎不会考虑去学习这么一门语言。因为它的并行,我看到的是一块用软件写出来的电路板,是的,它几乎就是把电脑变成了一个可以自由编写逻辑的芯片。

例程来自这里:http://www.erlang.org/doc/getting_started/conc_prog.html

 

例1 体会concurrent

bubuko.com,布布扣
-module(tut14).

-export([start/0, say_something/2]).

say_something(What, 0) ->
    done;
say_something(What, Times) ->
    io:format("~p~n", [What]),
    say_something(What, Times - 1).

start() ->
    spawn(tut14, say_something, [hello, 3]),
    spawn(tut14, say_something, [goodbye, 3]).
bubuko.com,布布扣

我们看到,除了最后两行,这其实和我们前面学到的没什么两样。。。最后两行出现了一个新鲜的BIF,spawn(),他有三个参数:

1. 参数2所在的模块名

2. 启动新进程后,执行哪个函数

3. 要传递给参数2的参数

两个spawn()事实上只启用了一个新的进程,一个用来执行say_something(hello, 3),一个用来执行say_something(goodbye, 3)。当然,他们是在同时执行的:

bubuko.com,布布扣
> c(tut14).
{ok,tut14}
> tut14:say_something(hello, 3).
hello
hello
hello
done
> tut14:start().
hello
goodbye
<0.39.0>
hello
goodbye
hello
goodbye
bubuko.com,布布扣

 

例2 发送和接收消息

通常意义上大家认为进程是独立运行的,不共享任何资源;而线程是需要共享资源的。我们不共享资源,所以把这里并行的叫做进程。但是,既然不共享资源,那该如何进行进程间通信呢?事实上,机制是唯一的:消息。我们可以根据进程的pid来发送消息,比如上面的<0.39.0>就是进程的pid。

bubuko.com,布布扣
-module(tut15).
-export([start/0, ping/2, pong/0]).

ping(0, Pong_PID) ->
    Pong_PID ! finished,
    io:format("ping finished~n", []);

ping(N, Pong_PID) ->
    Pong_PID ! {ping, self()},
    receive
        pong ->
            io:format("Ping received pong~n", [])
    end,
    ping(N - 1, Pong_PID).

pong() ->
    receive
        finished ->
            io:format("Pong finished~n", []);
        {ping, Ping_PID} ->
            io:format("Pong received ping~n", []),
            Ping_PID ! pong,
            pong()
    end.

start() ->
    Pong_PID = spawn(tut15, pong, []),
    spawn(tut15, ping, [3, Pong_PID]).
bubuko.com,布布扣

上面的代码里出现了两个生面孔:

1、Pong_PID ! finished。这就是前面提到的发送message。

2、receive...end。这句则是用来接收message;如pong()中的finished和{ping, Ping_PID}则是两项匹配条件,表示如果接收到的消息是这个或者那个,然后如何如何。如果接收到的消息是finished,那么在io中输出,pongfinished。

3、Pong_PID是由spawn返回的,而Ping_PID则是调用self()函数获取的。

执行的结果是:

bubuko.com,布布扣
> c("tut15").
{ok,tut15}
> tut15:
module_info/0  module_info/1  ping/2         pong/0         start/0        

> tut15:start().
Pong received ping
<0.47.0>
Ping received pong 
Pong received ping
Ping received pong 
Pong received ping
Ping received pong 
ping finished 
Pong finished
bubuko.com,布布扣

 

 

窥一斑而知全豹。

初次使用erlang的concurrent,布布扣,bubuko.com

初次使用erlang的concurrent

标签:style   blog   class   code   java   tar   

原文地址:http://www.cnblogs.com/pied/p/3715017.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!