Как запустить супервизора с работниками, которые не являются gen_servers? - PullRequest
Новая
       59

Как запустить супервизора с работниками, которые не являются gen_servers?

1 голос
/ 05 апреля 2020

Здравствуйте, я пытаюсь запустить supervisor, чьи работники не gen_server (s). Мой руководитель определен в том же модуле, что и работник, для краткости:

Я продолжаю получать эту ошибку, и я пытался поместить атрибут MFA в [ ] безрезультатно. Я также поставил ChildSpec в [ ]. Что мне не хватает?

Я не хочу, чтобы у моего руководителя были какие-либо работники при его запуске.

Ошибка 

>  X=sup:start_link().
> ** exception error: no match of right hand side value {error,
>                                                        {bad_start_spec,[]}}
>      in function  sup:start_link/0 (c:/Erlang/ProcessPool/sup.erl, line 6)
> =CRASH REPORT==== 5-Apr-2020::22:20:32.918000 ===   crasher:
>     initial call: supervisor:sup/1
>     pid: <0.280.0>
>     registered_name: []
>     exception exit: {bad_start_spec,[]}
>       in function  gen_server:init_it/6 (gen_server.erl, line 358)
>     ancestors: [<0.273.0>]
>     message_queue_len: 0
>     messages: []
>     links: [<0.273.0>]
>     dictionary: []
>     trap_exit: true
>     status: running
>     heap_size: 376
>     stack_size: 27
>     reductions: 205   neighbours:

Модуль 

-module(sup).
-behaviour(supervisor).
-compile([export_all]).

start_link() ->
     {ok, Pid} = supervisor:start_link({local, ?MODULE}, ?MODULE, []),
     Pid.

init(_Args) ->
     RestartStrategy = {simple_one_for_one, 10, 60},
    {ok, {RestartStrategy,[]}}.

add(Sup,Value)->                #adding child
    ChildSpec = {
                  ch1, 
                  {sup, start, [Value]},
                  permanent,
                  brutal_kill, 
                  worker, 
                  [ch1]
                },
    supervisor:start_child(Sup,ChildSpec).


start([Value])->                                    #child's start_link equivalent (non-genserver)
    spawn_link(?MODULE,initworker,[self(),Value]).

initworker(From,Value)->                            #child's init
    receive 
       MSG->From ! {got_msg,Value,MSG}
    end.

1 Ответ

3 голосов
/ 06 апреля 2020

Поскольку вы используете simple_one_for_one, вы должны определить ChildSpec в init, и все дети используют один и тот же ChildSpec.

Если вам нужно другое, используйте вместо этого стратегию one_for_one.

Для simple_one_for_one:

Второй аргумент supervisor:start_child/2 должен быть списком, который будет объединен с аргументами по умолчанию для аргументов дочерней функции запуска, определенных в ChildSpec.

Здесь я быстро изменил код, чтобы он работал для вас. 

-module(sup).
-behaviour(supervisor).
-compile([export_all]).

start_link() ->
     {ok, Pid} = supervisor:start_link({local, ?MODULE}, ?MODULE, []),
     Pid.

init(_Args) ->
     RestartStrategy = {simple_one_for_one, 10, 60},
     ChildSpec = {
                  ch1, 
                  {sup, start, []},
                  permanent,
                  brutal_kill, 
                  worker,
                  [sup]
                },
    {ok, {RestartStrategy,[ChildSpec]}}.

add(Sup,Value)->                
    supervisor:start_child(Sup,[Value]).


start(Value)->                                    
    P = spawn(?MODULE, initworker,[]),
    P!{self(),Value},
    {ok,P}.

initworker()->                            
    receive 
       {From, MSG} -> io:format(" Value is ~p~n", [MSG])
    end.
...