关于task.supervisor.async_stream_nolink的示例？

Question

defmodule MySupervisor do
    use Supervisor

    def start_link do
        Supervisor.start_link(__MODULE__, [])
    end

    def init([]) do
        children= [
            worker(Basic, [])
        ]

        supervise(children, strategy: :one_for_one)
    end
end

defmodule Basic do
    use GenServer

    def start_link do
        GenServer.start_link(__MODULE__, [], name: __MODULE__)
    end
end


strings = ["long string", "longer string", "there are many of these"]


stream = Task.Supervisor.async_stream_nolink(MySupervisor, strings, fn text -> text |> String.codepoints |> Enum.count end)


Enum.reduce(stream, 0, fn {:ok, num}, acc -> num + acc end) |> IO.puts

但是，我搞错了：

**（退出#pid<0.70.0>)退出于：genserver.call（MySupervisor,{:start_child,[#pid<0.70.0>,：Monitor,{:nonode@nohost,#pid<0.81.0>},{:erlang,：apply,[#function<0.118488666 in file:test.exs>,[“long st ring”]]}]},：infinity）**（退出）无进程：进程不活动,或者当前没有与给定名称关联的进程,可能是因为其应用程序未启动

16:24:34.317[错误]GenServer#pid<0.79.0>正在终止**（停止）退出于：GenServer.call（MySupervisor,{:start_child,[#pid<0.70.0>,：monitor,{:nonode@nohost,#pid<0.81.0>},{:erlang,：apply,[#function<0.118488666 in file:test.exs>,[“long string”]]}]},：infinity）**(EXIT)无进程：进程不活动,或者当前没有与给定名称相关联的进程,可能是因为其应用程序未启动上一条消息：{：EXIT,#pid<0.70.0>,{：noproc,{GenServer,：call,[MySupervisor,{:start_child,[#pid<0.70.0>,：monitor,{:nonode@nohost,#pid<0.81.0>},{:erlang,：apply,[#function<0.118488666 in file：test.exs

,[“长字符串”]]}]},：Infinity]}}状态：{：state,{#pid<0.79.0>,MySupervisor},：One_for_One,[{：child,#pid<0.80.0>,Basic,{Basic,：start_link,[]},：permanent,5000,：worker,[Basic]}],：undefined,3,5,[],0,MySupervisor,[]}

有人能帮忙吗？我找不到关于使用task.supervisor.async_stream_nolink的示例

编辑

{:ok, supervisor} = MySupervisor.start_link
stream = Task.Supervisor.async_stream_nolink(supervisor, strings, fn text -> text |> String.codepoints |> Enum.count end)
Enum.reduce(stream, 0, fn {:ok, num}, acc -> num + acc end) |> IO.puts

**（EXIT from#pid<0.70.0>)出现异常:**（MatchError）右侧值不匹配：{：错误,{：EXIT,{：undef,[{Basic,：start_link,[#pid<0.70.0>,：monitor,{：nonode@nohost,#pid<0.81.0>},{：erlang,：apply,[#file:test.exs>,[“long string”]]},[#function<0.20003547 in file:test.exs>,[“long string”]]},{：supervisor,:do_start_child_i,3,[file:'supervisor.erl',行:381]},{：supervisor,：handle_call,3,[file:'supervisor.erl',行：406]},{:gen_server,:try_handle_call,4,[文件：“gen_server.erl”,行:615]},{:gen_server,:handle_msg,5,[文件：“gen_server.erl”,行:647]},{:proc_lib,:init_p_do_apply,3,[文件：“proc_lib.erl”,行:247]}]}}}(elixir)lib/task.supervisor.ex:265:task.supervisor.build_stream中的匿名FN/4(elixir)lib/task.supervisor.ex:332:task.supervisor.stream_monitor/6

17:07:53.497[error]进程#pid<0.81.0>引发异常**（MatchError）右侧值不匹配：{：错误,{：exit,{：undef,[{Basic,：start_link,[#pid<0.70.0>,：monitor,{：nonode@nohost,#pid<0.81.0>},{：erlang,：apply,[#file:test.exs>,[“long string”]]},[#function<0.20003547 in file:test.exs>,[“long string”]]},{：supervisor,：do_start_child_i,3,[file:'supervisor.erl',line:381]},{：supervisor,：handle_call,3,[file:'supervisor.erl'行:406]},{:gen_server,:try_handle_call,4,[文件：“gen_server.erl”,行:615]},{:gen_server,:handle_msg,5,[文件：“gen_server.erl”,行:647]},{:proc_lib,:init_p_do_apply,3,[文件：“proc_lib.erl”,行:247]}]}}(elixir)lib/task.supervisor.ex:265:task.supervisor.build_stream中的匿名FN/4(elixir)lib/task.supervisor.ex:332:task.supervisor.stream_monitor/6

17:07:53.503[错误]GenServer MySupervisor终止**（MatchError）右侧值不匹配：{：错误,{：exit,{：undef,[{Basic,：start_link,[#pid<0.70.0>,：monitor,{：nonode@nohost,#pid<0.81.0>},{：erlang,：apply,[#file:test.exs>,[“长字符串”]]}],[]},{：supervisor,:do_start_child_i,3,[文件:'supervisor.erl',行:381]},{：supervisor,：handle_call,3,[文件:'supervisor.erl',行:406]},{:gen_server,:try_handle_call,4,[文件：“gen_server.erl”,行:615]},{:gen_server,:handle_msg,5,[文件：“gen_server.erl”,行:647]},{:proc_lib,:init_p_do_apply,3,[文件：“proc_lib.erl”,行:247]}]}}}(elixir)lib/task.supervisor.ex:265:匿名FN/4中的task.supervisor.build_stream/5(elixir)lib/task.supervisor.ex:332:task.supervisor.stream_monitor/6最后一条消息：{：exit,#pid<0.70.0>,{{：BADMATCH,{：error,{：EXIT,{：UNDEF,[{Basic,：START_LINK,[#PID<0.70.0>,：Monitor,{:Nonode@NoHost,#PID<0.81.0>},{：Erlang,：APPLY,[#FUNCTION<0.20003547文件：test.ex S>,[“长字符串”]]}],[]},{:supervisor,:do_start_child_i,3,[文件：“supervisor.erl”,行:381]},{:supervisor,：handle_call,3,[文件：“supervisor.erl”,行:406]},{:gen_server,:try_handle_call,4,[f文件：“gen_server.erl”,行:615]},{:gen_server,:handle_msg,5,[文件：“gen_server.erl”,行:647]},{:proc_lib,:init_p_do_apply,3,[文件：“proc_lib.erl”,行:247]}]}}}},[{task.supervisor,：“-build_str eam/5-fun-0-”,4,[文件：“lib/task/supervisor.ex”,行:265]},{task.supervisor,:stream_monitor,6,[文件：“lib/task/supervisor.ex”,行:332]}]}}}状态：{：state,{：local,MySupervisor},:simple_one_for_one,[{：child,：undefined,Basic,{Basic,：start_link,[]},：permanent,5000,：worker,[Basic]},：undefined,3,5,[],0,MySupervisor,[]}

Answer 1

task.Supervisor中的函数只能在使用task.Supervisor.start_link/1启动的Supervisor上运行。

您可以启动一个未命名的实例并将pid传递给async_stream_nolink/4:

{:ok, supervisor} = Task.Supervisor.start_link
stream = Task.Supervisor.async_stream_nolink(supervisor, strings, fn text -> text |> String.codepoints |> Enum.count end)

或启动命名实例并传递其名称：

Task.Supervisor.start_link name: MySupervisor
stream = Task.Supervisor.async_stream_nolink(MySupervisor, strings, fn text -> text |> String.codepoints |> Enum.count end)

children = [
  supervisor(Task.Supervisor, [name: MySupervisor]),
  ...
]

Task.Supervisor.async_stream_nolink(MySupervisor, ...)