erlang

erlang最基本的单位process

2019-12-10  本文已影响0人  Alking

erlang最基本的单位process

process 是erlang中最基本的单位,只有process才能获取cpu的时间片。熟悉java的开发人员都知道,在java中要想获得cpu的时间片,也必须是Thread.不过java中的Thread是重资源对象,new一个Thread和释放一个Thread开销很大,这点erlang的process却是相反,process的开销很小,几乎可以任意的创建。

1. 如何创建process
  1. erlang:spawn|proc_lib:spawn
  2. erlang:spawn_link|proc_lib:spawn_link
  3. erlang:spawn_monitor|proc_lib:spawn_monitor
2.如何查看process的状态

使用erlang:process_info(Pid..)可以看到该process的各种状态,最常见的要数:

这个函数可以很快的诊断pid的状态,在debug的时候非常有用

3.如何结束一个process
4. process 之间连接(link) 同生共死

link的用途之一就是将2个process绑在一起,只要有一方非正常退出,另一process也会退出,下面举个例子:

% example1:正常退出
Eshell V10.2  (abort with ^G)
1> P = erlang:spawn(fun()-> receive M -> io:format("receve ~p~n",[M]),exit(normal) end end). % exit(normal) 正常退出
<0.78.0>
2> 
2> P2 = erlang:spawn(fun()-> link(P),receive M -> io:format("p2 receve ~p~n",[M]) end end).                            
<0.80.0>
3> {erlang:is_process_alive(P),erlang:is_process_alive(P2)}.
{true,true}
4> P ! ok.
receve ok
ok
5> {erlang:is_process_alive(P),erlang:is_process_alive(P2)}.
{false,true}

% P正常推出了,所以P2没有退出,还活着


% example2:非正常退出
Erlang/OTP 21 [erts-10.2] [source] [64-bit] [smp:4:4] [ds:4:4:10] [async-threads:1]

Eshell V10.2  (abort with ^G)
1> P = erlang:spawn(fun()-> receive M -> io:format("receve ~p~n",[M]),exit(M) end end).      
<0.78.0>
2> 
2> P2 = erlang:spawn(fun()-> link(P),receive M -> io:format("p2 receve ~p~n",[M]) end end). 
<0.80.0>
3> 
3> P ! ok.
receve ok
ok
4> {erlang:is_process_alive(P),erlang:is_process_alive(P2)}.
{false,false}
% p2 receive...没有打印出来就exit掉了
5> 
5. link记得process_flag(trap_exit, true)

就像上面的例子一样,如果不加这个语句,就无法收到一方退出的消息,加上这句就可以捕获这条消息,从而处理自己的逻辑,例子如下:

1> P = erlang:spawn(fun()-> receive M -> io:format("receve ~p~n",[M]),exit(M) end end).    
<0.78.0>
2>    
2>    P2 = erlang:spawn(fun()-> link(P),process_flag(trap_exit, true),  receive M -> io:format("p2 receve ~p~n",[M]) end end).
<0.80.0>
3> P ! ok.
receve ok
ok
p2 receve {'EXIT',<0.78.0>,ok}
% 正常捕获P退出的消息了
6.连接(link) 和监控(monitor)

与link不同的是,monitor是单向的,举个例子
ProcA 与 ProcB 连接,那么任何一方exit掉,对方都能收到消息
ProcA monitor ProcB,只有ProcB退出,ProcA才能收到消息,换句话说ProcA退出,ProcB是无法收到ProcA退出的消息的

总结

熟练掌握process的生命周期,以及process之间的相互link,monitor的行为,可以避免在编码过程中踩坑。

上一篇下一篇

猜你喜欢

热点阅读