Erlang: Supervisor (3), добавив дочерний процесс

Question

Где я могу найти пример того, как добавить динамические детские процессы к существующему руководителю (simple_one_for_one стратегия перезапуска)?

Answer 1

Я провел некоторое исследование, и ниже это то, что у меня есть.

Во -первых, это образец обратного модуля руководителя:

-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}}.

И это модуль обратного вызовов ребенка, который будет динамически добавлен в дерево Вервенса:

-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}.

Вот как мы обычно начинаем руководителя:

1> ch_sup:start_link().
{ok,<0.33.0>}

Теперь давайте начнем наш первый дочерний процесс:

2> {ok, Child1Pid} = supervisor:start_child(ch_sup, []).
ch1 has started (<0.35.0>)
{ok,<0.35.0>}

Вы можете динамически запустить дочерние процессы; Давайте начнем другого ребенка:

3> {ok, Child2Pid} = supervisor:start_child(ch_sup, []).
ch1 has started (<0.37.0>)
{ok,<0.37.0>}

Вы можете увидеть, что наши процессы начались (обратите внимание на последние два):

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>]

Теперь давайте сделаем наш первый дочерний процесс.

5> gen_server:cast(Child1Pid, calc).
result 2+2=4
ok

Все идет нормально. Теперь мы заставим нашего первого ребенка оценить плохой код:

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>

В отчете вы можете увидеть, что разделение по нулю вызвало исключение, и процесс был прекращен. Но супервайзер позаботится об этом и сразу же запускает другой дочерний процесс (обратите внимание на последнюю строку).

Мы можем проверить, чтобы убедиться, что другой дочерний процесс, который мы начинали ранее, все еще жив (примечание <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>

Мы можем даже заставить это сделать что -то для нас:

8> gen_server:cast(Child2Pid, calc).   
result 2+2=4
9>

---

Ниже приведены ручные страницы Erlang, которые вы захотите прочитать:

• Поведение руководителя
• руководитель (3)
• gen_server (3)

Answer 2

В Поведение руководителя раздел ОТП принципы дизайна часть документов Erlang есть пример того, как использовать simple_one_for_one и динамичные дети. Я рекомендую всю часть принципов дизайна, поскольку она дает много понимания того, как работает OTP.