Code@Pig Home

大家好，欢迎收看KKTV的《每日一Errr~lang》节目，今天我们来看看 erlang 中关于 process 的一些基础知识。

创建 process / 消息通讯
弄个简单的程序，然后通过 spawn(mod, name, args) 来创建一个 process。
-------------------------------------------------------
-module(myworker).
-export([loop/0]).

loop() ->
    receive
        {foo, Val} ->
            io:format("foo = ~p~n", [Val]);
        {bar, Val} ->
            io:format("bar = ~p~n", [Val])
    end,
    loop().
-------------------------------------------------------
1> c(myworker).
{ok,myworker}
2> Pid = spawn(myworker, loop, []).
<0.38.0>
3> Pid ! {foo, "hello"}.
foo = "hello"
{foo,"hello"}
4> Pid ! {bar, a_atom}.
bar = a_atom
{bar,a_atom}
5> Pid ! {no_this}.     
{no_this}
-------------------------------------------------------
给一个 process 发消息非常简单吧，呵呵。还可以 Pid1 ! Pid2 ! ... ! Msg 同时给多个 process 发消息。

消息的处理顺序
对于一个 process，当 receive 时，相当于 block 住，直到有满足条件的消息到达时，才会唤醒 process。
-------------------------------------------------------
-module(message).
-export([loop/0]).

loop2() ->
    receive
        {bar, Val} ->
            io:format("bar = ~p~n", [Val])
    end,
    loop().

loop() ->
    receive
        {foo, Val} ->
            io:format("foo = ~p~n", [Val])
    end,
    loop2().
-------------------------------------------------------
1> c(message).
{ok,message}
2> Pid = spawn(fun message:loop/0).
<0.38.0>
3> Pid ! {bar, "hello"}.
{bar,"hello"}
4> Pid ! {foo, "cool"}.
foo = "cool"
{foo,"cool"}
bar = "hello"
-------------------------------------------------------

消息返回值
我们给一个 process 发消息，相当于调用 process 的一个函数，我们希望有个函数返回值，怎么做呢？
-------------------------------------------------------
-module(myserver).
-export([rpc/2, loop/0]).

rpc(Pid, Request) ->
    Pid ! {self(), Request},
    receive
        {Pid, Response} ->            % 这里 Pid 保证了返回值来自于期望的 process
            Response
    end.

loop() ->
    receive
        {From, {add, A, B}} ->
            From ! {self(), A+B},
            loop();
        {From, {sub, A, B}} ->
            From ! {self(), A-B},
            loop();
        {From, Other} ->
            From ! {self(), {error, Other}},
            loop()
    end.
-------------------------------------------------------
1> c(myserver).
{ok,myserver}
2> Pid = spawn(fun myserver:loop/0).
<0.38.0>
3> myserver:rpc(Pid, {add, 2, 1}).
3
4> myserver:rpc(Pid, {sub, 2, 1}).
1
5> myserver:rpc(Pid, {no_such, 2, 1}).
{error,{no_such,2,1}}
-------------------------------------------------------

消息的 timeout
某些 process，希望5秒内接受某消息，5秒过去还未收到，则做一些别的处理。
-------------------------------------------------------
-module(mytimeout).
-export([loop/0]).

loop() ->
    receive
        {foo, Val} ->
            io:format("foo = ~p~n", [Val]);
        {bar, Val} ->
            io:format("bar = ~p~n", [Val])
    after
        timer:seconds(5) ->
            io:format("timeout~n")
    end,
    loop().
-------------------------------------------------------
1> c(mytimeout).
{ok,mytimeout}
2> Pid = spawn(fun mytimeout:loop/0).
<0.38.0>
3> Pid ! {foo, "hello"}.
foo = "hello"
{foo,"hello"}
timeout
timeout
-------------------------------------------------------

Registered Process
对于常用功能的 process，使用 Pid 实在不方便，我们可以把 Pid 与一个 atom 关联，这样调用起来就方便了。
-------------------------------------------------------
1> c(myworker).
{ok,myworker}
2> Pid = spawn(fun myworker:loop/0).
<0.38.0>
3> register(coolworker, Pid).
true
4> coolworker!{foo, "hello"}.
foo = "hello"
{foo,"hello"}
5> whereis(coolworker).
<0.38.0>
6> registered().
<0.38.0>
7> registered().
[code_server,user_drv,error_logger,rex,standard_error,
 standard_error_sup,erl_prim_loader,application_controller,
 kernel_sup,init,global_name_server,kernel_safe_sup,
 coolworker,global_group,file_server_2,inet_db,user]
8> unregister(coolworker).
true
9> whereis(coolworker).
undefined
-------------------------------------------------------

时间飞逝，今天的内容讲解完毕，大家懂了么？如有疑问，可以拨打我们的免费电话 000-5412226，我们将竭诚为您解答。