erlang最基本的单位process
process 是erlang中最基本的单位,只有process才能获取cpu的时间片。熟悉java的开发人员都知道,在java中要想获得cpu的时间片,也必须是Thread.不过java中的Thread是重资源对象,new一个Thread和释放一个Thread开销很大,这点erlang的process却是相反,process的开销很小,几乎可以任意的创建。
1. 如何创建process
erlang:spawn|proc_lib:spawn
erlang:spawn_link|proc_lib:spawn_link
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的行为,可以避免在编码过程中踩坑。