erlang最基本的单位process

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的各种状态,最常见的要数:

  • message_queue_len 未处理的消息数,可以看到当前process是否繁忙
  • dictionary 进程字典
  • status 当前调度状态
  • initial_call 初始化参数
  • current_function 当前运行到哪里

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

3.如何结束一个process
  • 当一个process正常结束,或者是function正常结束
  • 或者主动调用 erlang:exit(Reason),当Reason = normal时候正常退出,反之异常退出
  • 调用 erlang:error(Reason)或者erlang:throw(Any)异常退出
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的行为,可以避免在编码过程中踩坑。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容