2017-04-14 3 views
2

this answerに記載されているようなものを実装しようとしていますが、アプリケーションをコンパイルするときに以下に説明したようなエラーが表示されます。私は本質的に私はここに許可されていないよ、または私はほんの少しのミスを犯してきた何かをやっている場合監視ツリーの開始に失敗する

** (Mix) Could not start application workers: Workers.Application.start(:normal, []) returned an error: shutdown: failed to start child: {Workers.UrlSupervisor, 2} 
    ** (EXIT) already started: #PID<0.1034.0> 

私はわかりません。ここ

defmodule Workers.Application do 
    # See http://elixir-lang.org/docs/stable/elixir/Application.html 
    # for more information on OTP Applications 
    @moduledoc false 

    use Application 

    def start(_type, _args) do 
    import Supervisor.Spec, warn: false 

    url_workers = 1..100 |> Enum.map(fn (i) -> supervisor(Workers.UrlSupervisor, [i], [id: {Workers.UrlSupervisor, i}, restart: :temporary]) end) 
    domain_workers = 1..100 |> Enum.map(fn (i) -> supervisor(Workers.DomainSupervisor, [i], [id: {Workers.DomainSupervisor, i}, restart: :temporary]) end) 

    opts = [strategy: :one_for_one, name: Workers.Supervisor] 
    Supervisor.start_link(url_workers ++ domain_workers, opts) 
    end 
end 

defmodule Workers.UrlSupervisor do 
    def start_link(id) do 
    import Supervisor.Spec, warn: false 

    children = [worker(Task, [&Workers.Url.worker/0], [id: {Workers.Url, id}, restart: :permanent])] 

    opts = [strategy: :one_for_one, name: Workers.UrlSupervisor] 
    Supervisor.start_link(children, opts) 
    end 
end 

defmodule Workers.DomainSupervisor do 
    def start_link(id) do 
    import Supervisor.Spec, warn: false 

    children = [worker(Task, [&Workers.Domain.worker/0], [id: {Workers.Domain, id}, restart: :permanent])] 

    opts = [strategy: :one_for_one, name: Workers.DomainSupervisor] 
    Supervisor.start_link(children, opts) 
    end 
end 

と労働者の一つである(彼らはほぼ同じに見える):ここではいくつかの状況については

は上司です。あなたの Workers.Application

defmodule Workers.Domain do 
    def worker do 
    case Store.Domains.pop do 
     :empty -> 
     IO.puts "[Domain] none found, waiting..." 
     :timer.sleep(1000) 
     {crawl_id, domain} -> 
     IO.puts "[Domains] found a domain to check: #{domain}" 
     case Core.check_domain(domain) do 
      :error -> 
      Utils.insert(crawl_id, domain, false) 
      :registered -> 
      Utils.insert(crawl_id, domain, false) 
      :available -> 
      Utils.insert(crawl_id, domain, true) 
     end 
    end 
    worker() 
    end 
end 
+3

が、彼らはまた、独自の持っている必要があります。:"url_supervisor_#{i}"を名前。あなたは 'name :::url_supervisor _#{i} ''のような別のキーワードを追加してみることができますか? –

+0

完全にそれを固定しました、私の愚かな間違い!これを答えにすると、私はそれを受け入れるでしょう:) – Zen

+1

完了。助けてうれしい! –

答えて

2

は、Supervisor秒の起動時にyou'rは、ユニークなid秒を提供し、彼らはまた、独自のname秒を持っている必要があります。

てみてください別のキーワード、名前のようなもの追加: `Supervisor`s、ご提供するユニークな` id`sを開始するとき、あなたの `Workers.Application`で

def start(_type, _args) do 
    import Supervisor.Spec, warn: false 

    url_workers = 1..100 |> Enum.map(fn (i) -> 
    supervisor(Workers.UrlSupervisor, [i], 
       [id: {Workers.UrlSupervisor, i}, 
       name: :"url_supervisor_#{i}", # Name added here 
       restart: :temporary]) 
    end) 
    domain_workers = 1..100 |> Enum.map(fn (i) -> 
    supervisor(Workers.DomainSupervisor, [i], 
       [id: {Workers.DomainSupervisor, i}, 
       name: :"domain_supervisor_#{i}", # Name added here 
       restart: :temporary]) 
    end) 

    opts = [strategy: :one_for_one, name: Workers.Supervisor] 
    Supervisor.start_link(url_workers ++ domain_workers, opts) 
end 
関連する問題