프로세스 링의 링크 비대칭

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을 생성하고 링크를 수집하면 빈 목록이됩니다. 지금 b를 생성하고 a에 연결하면

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

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

각 프로세스에 대한 최종 링크를 원한다면 모든 연결이 완료된 후에 각 프로세스에 대한 링크를 수집해야합니다.