プロセスリングの非対称性のリンク

Question

私は現在、エリクシルのユビキタスプロセスリングを使っています。 リングがリンクされているが、以下の方法で：

iex(1)> Ring.Worker.create_ring_of_linked_processes(3) 
Ring.Worker.create_ring_of_linked_processes(3) 
[%{"links" => [#PID<0.121.0>, #PID<0.120.0>], "pid" => #PID<0.122.0>}, 
%{"links" => [#PID<0.120.0>, #PID<0.122.0>], "pid" => #PID<0.121.0>}, 
%{"links" => [#PID<0.121.0>], "pid" => #PID<0.120.0>}] 

私はここのリンクの非対称性を気づいた - #PID<0.120.0>マッピング"links" => [#PID<0.121.0>,#PID<0.122.0>]だけでなく"links" => [#PID<0.121.0>]を持っている必要がありますか？あなたはその:linksを集めると同時にプロセスをリンクしているので、これがある

def loop() do 
    receive do 
     {:link, pid} when is_pid(pid) -> 
     Process.link(pid) 
     loop() 
    end 
    end 

    def create_ring_of_linked_processes(num_of_processes) do 
    num_of_processes 
    |> create_processes 
    |> link_processes([]) 
    end 


    def link_processes([pid1, pid2 | rest], linked_processes) do 
    send(pid1, {:link, pid2}) 
    :timer.sleep(1) 
    {:links, links} = Process.info(pid1, :links) 
    link_processes(
     [pid2 | rest], [%{"pid" => pid1, "links" => links} | linked_processes] 
    ) 
    end 

    def link_processes([pid | []], linked_processes) do 
    %{"pid" => first_pid, "links" => _} = List.last(linked_processes) 
    send(pid, {:link, first_pid}) 
    :timer.sleep(1) 
    {:links, links} = Process.info(pid, :links) 
    [%{"pid" => pid, "links" => links} | linked_processes] 
    end 

    @spec create_processes(integer) :: [pid] 
    def create_processes(num_of_processes) do 
    for _ <- 1..num_of_processes, do: spawn(__MODULE__, :loop, []) 
    end 

Answer 1

が、そのプロセスのためのいくつかのリンクは、あなたがその収集後に作成されている次のように

コードがありますリンク。

たとえば、プロセスaを生成してリンクを収集すると、空のリストになります。

iex(1)> a = spawn(fn -> :timer.sleep(:infinity) end) 
#PID<0.82.0> 
iex(2)> Process.info(a, :links) 
{:links, []} 

あなたが今bを起動し、aにリンクした場合、bは、そのリンクで[a]を持つことになりますし、aは[b]を持つことになります。

iex(3)> b = spawn(fn -> Process.link(a); :timer.sleep(:infinity) end) 
#PID<0.85.0> 
iex(4)> Process.info(b, :links) 
{:links, [#PID<0.82.0>]} 
iex(5)> Process.info(a, :links) 
{:links, [#PID<0.85.0>]} 

したがって、各プロセスの最終リンクを希望する場合は、すべてのリンクが完了した後に各プロセスのリンクを収集する必要があります。