美文网首页erlang
erlang最基本的单位process

erlang最基本的单位process

作者: Alking | 来源:发表于2019-12-10 00:25 被阅读0次

    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的行为,可以避免在编码过程中踩坑。

    相关文章

      网友评论

        本文标题:erlang最基本的单位process

        本文链接:https://www.haomeiwen.com/subject/ltkwgctx.html