我有一个测试模块和一个simple_one_for_one主管。
test.erl
-module(test).
-export([
run/1,
do_job/1
]).
run(Fun) ->
test_sup:start_child([Fun]).
do_job(Fun) ->
Pid = spawn(Fun),
io:format("started ~p~n", [Pid]),
{ok, Pid}.
test_sup.erl
-module(test_sup).
-behaviour(supervisor).
-export([start_link/0]).
-export([init/1]).
-export([start_child/1]).
start_link() ->
supervisor:start_link({local, ?MODULE}, ?MODULE, []).
init(_Args) ->
SupFlags = #{strategy => simple_one_for_one, intensity => 2, period => 20},
ChildSpecs = [#{id => test,
start => {test, do_job, []},
restart => permanent,
shutdown => brutal_kill,
type => worker,
modules => [test]}],
{ok, {SupFlags, ChildSpecs}}.
start_child(Args) ->
supervisor:start_child(?MODULE, Args).
我通过命令test_sup:start_link()
在shell中启动超级用户。之后,我运行以下命令:test:run(fun() -> erlang:throw(err) end).
除函数do_job
外,我重新启动了2次,但从未执行。有什么问题吗?
这里是外壳:
1> test_sup:start_link().
{ok,<0.36.0>}
2> test:run(fun() -> erlang:throw(err) end).
started <0.38.0>
{ok,<0.38.0>}
3>
=ERROR REPORT==== 16-Dec-2016::22:08:41 ===
Error in process <0.38.0> with exit value:
{{nocatch,err},[{erlang,apply,2,[]}]}
重新启动子级与simple_one_for_one
主管的定义相反。根据supervisor docs:
[delete_child / 2和restart_child / 2函数对于simple_one_for_one主管无效,如果指定的主管使用此重新启动策略,则返回{error,simple_one_for_one}。
换句话说,您要的东西永远不会发生。这是因为simple_one_for_one
适用于动态子级,这些动态子级在您请求子级时通过传入其他启动arg来动态定义。其他主管可以重新启动其子级,因为在该主管中静态定义了启动args。
基本上,这种类型的主管完全是为了确保在需要动态工作人员池时有条不紊地关闭计算机。