Link Asymmetrie im Prozess Ring

Question

Ich arbeite derzeit durch den allgegenwärtigen Prozess Ring in Elixier. Der Ring ist verbunden, aber in der folgenden Art und Weise:

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>}] 

Ich habe eine Asymmetrie in den Links hier bemerkt - sollte #PID<0.120.0> haben die Zuordnung "links" => [#PID<0.121.0>,#PID<0.122.0>] anstatt nur "links" => [#PID<0.121.0>]?

Der Code ist wie folgt:

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

Dies ist, weil Sie die Prozesse zur gleichen Zeit sind die Verknüpfung als :links zu sammeln, aber einige Links für diesen Prozess sind erstellt werden, nachdem Sie seine sammeln Links.

Zum Beispiel, wenn Sie einen Prozess a spawnen und dann seine Links sammeln, wird es eine leere Liste sein.

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

Wenn Sie b jetzt und verknüpfen es mit a laichen, wird b[a] in seiner Verbindungen haben und a wird [b] haben.

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>]} 

So müssen Sie die Links für jeden Prozess sammeln, nachdem alle die Verknüpfung abgeschlossen ist, wenn Sie die Endglieder für jeden Prozess wollen.