0xA*_*xAX 14 erlang erlang-otp erlang-supervisor
我在哪里可以找到有关如何将动态子进程添加到现有主管的示例(simple_one_for_one
重启策略)?
Yas*_*aev 17
我做了一些研究,下面是我的研究.
首先,这是一个主管的示例回调模块:
-module(root_sup).
-behaviour(supervisor).
-export([start_link/0]).
-export([init/1]).
start_link() ->
{ok, Pid} = supervisor:start_link({local, ?MODULE},
?MODULE, []),
{ok, Pid}.
init(_Args) ->
RestartStrategy = {simple_one_for_one, 10, 60},
ChildSpec = {ch1, {ch1, start_link, []},
permanent, brutal_kill, worker, [ch1]},
Children = [ChildSpec],
{ok, {RestartStrategy, Children}}.
Run Code Online (Sandbox Code Playgroud)
这是一个子项的回调模块,它将动态添加到suprervision树中:
-module(ch1).
-behaviour(gen_server).
% Callback functions which should be exported
-export([init/1]).
-export([handle_cast/2]).
% user-defined interface functions
-export([start_link/0]).
start_link() ->
gen_server:start_link(?MODULE, [], []).
init(_Args) ->
io:format("ch1 has started (~w)~n", [self()]),
% If the initialization is successful, the function
% should return {ok,State}, {ok,State,Timeout} ..
{ok, ch1State}.
handle_cast(calc, State) ->
io:format("result 2+2=4~n"),
{noreply, State};
handle_cast(calcbad, State) ->
io:format("result 1/0~n"),
1 / 0,
{noreply, State}.
Run Code Online (Sandbox Code Playgroud)
这就是我们通常启动主管的方式:
1> ch_sup:start_link().
{ok,<0.33.0>}
Run Code Online (Sandbox Code Playgroud)
现在让我们开始我们的第一个子进程:
2> {ok, Child1Pid} = supervisor:start_child(ch_sup, []).
ch1 has started (<0.35.0>)
{ok,<0.35.0>}
Run Code Online (Sandbox Code Playgroud)
您可以动态启动子进程; 让我们开始另一个孩子:
3> {ok, Child2Pid} = supervisor:start_child(ch_sup, []).
ch1 has started (<0.37.0>)
{ok,<0.37.0>}
Run Code Online (Sandbox Code Playgroud)
你可能会看到我们的流程确实开始了(注意最后两个):
4> erlang:processes().
[<0.0.0>,<0.2.0>,<0.4.0>,<0.5.0>,<0.7.0>,<0.8.0>,<0.9.0>,
<0.10.0>,<0.11.0>,<0.12.0>,<0.13.0>,<0.14.0>,<0.15.0>,
<0.16.0>,<0.17.0>,<0.18.0>,<0.19.0>,<0.20.0>,<0.21.0>,
<0.22.0>,<0.23.0>,<0.24.0>,<0.25.0>,<0.26.0>,<0.27.0>,
<0.31.0>,<0.33.0>,<0.35.0>,<0.37.0>]
Run Code Online (Sandbox Code Playgroud)
现在让我们让我们的第一个子进程做一些事情:
5> gen_server:cast(Child1Pid, calc).
result 2+2=4
ok
Run Code Online (Sandbox Code Playgroud)
到现在为止还挺好.现在我们将让我们的第一个孩子评估一些不好的代码:
6> gen_server:cast(Child1Pid, calcbad).
result 1/0
ok
7>
=ERROR REPORT==== 10-Feb-2011::01:32:15 ===
** Generic server <0.35.0> terminating
** Last message in was {'$gen_cast',calcbad}
** When Server state == ch1State
** Reason for termination ==
** {'function not exported',
[{ch1,terminate,
[{badarith,
[{ch1,handle_cast,2},
{gen_server,handle_msg,5},
{proc_lib,init_p_do_apply,3}]},
ch1State]},
{gen_server,terminate,6},
{proc_lib,init_p_do_apply,3}]}
ch1 has started (<0.42.0>)
7>
Run Code Online (Sandbox Code Playgroud)
在报告中,您可能会看到除以零导致异常,并且该过程已终止.但主管负责处理并立即开始另一个子进程(注意最后一行).
我们可以检查以确保我们之前开始的其他子进程仍然存在(注意<0.37.0>
):
7> erlang:processes().
[<0.0.0>,<0.2.0>,<0.4.0>,<0.5.0>,<0.7.0>,<0.8.0>,<0.9.0>,
<0.10.0>,<0.11.0>,<0.12.0>,<0.13.0>,<0.14.0>,<0.15.0>,
<0.16.0>,<0.17.0>,<0.18.0>,<0.19.0>,<0.20.0>,<0.21.0>,
<0.22.0>,<0.23.0>,<0.24.0>,<0.25.0>,<0.26.0>,<0.27.0>,
<0.31.0>,<0.33.0>,<0.37.0>,<0.42.0>]
8>
Run Code Online (Sandbox Code Playgroud)
我们甚至可以让它为我们做点什么:
8> gen_server:cast(Child2Pid, calc).
result 2+2=4
9>
Run Code Online (Sandbox Code Playgroud)
以下是您想要阅读的Erlang手册页: