В Gossip GenServer процессы умирают до выхода из условия - PullRequest
Новая
       72

В Gossip GenServer процессы умирают до выхода из условия

0 голосов
/ 01 октября 2018

Я создаю несколько GenServers сплетен, отправляя сообщения друг другу.Я установил условие выхода, чтобы каждый процесс умирал после получения 10 сообщений.Каждый GenServer создается в начале сплетни в функции launch.

defmodule Gossip do
    use GenServer

    # starting gossip
    def start_link(watcher \\ nil), do: GenServer.start_link(__MODULE__, watcher)
    def init(watcher), do: {:ok, {[],0,watcher}}
    def launch(n, watcher \\ nil) do
        crew = (for _ <- 0..n, do: elem(Gossip.start_link(watcher),1))
        Enum.map(crew, &(add_crew(&1,crew--[&1])))
        crew
            |> hd()
            |> Gossip.send_msg()
    end 


    # client side
    def add_crew(pid, crew), do: GenServer.cast(pid, {:add_crew, crew})
    def rcv_msg(pid, msg \\ ""), do: GenServer.cast(pid, {:rcv_msg, msg})
    def send_msg(pid, msg \\ ""), do: GenServer.cast(pid, {:send_msg, msg})


    # server side  
    def handle_cast({:add_crew, crew}, {_, msg_counter, watcher}), do:
        {:noreply, {crew, msg_counter, watcher}}

    def handle_cast({:rcv_msg, _msg}, {crew, msg_counter, watcher}) do
        if msg_counter < 10 do
            send_msg(self())
        else
            GossipWatcher.increase(watcher)
            IO.inspect(self(), label: "exit of:") |> Process.exit(:normal)
        end
        {:noreply, {crew, msg_counter+1, watcher}}
    end

    def handle_cast({:send_msg,_},{[],_,_}), do: Process.exit(self(),"crew empty")
    def handle_cast({:send_msg, _msg}, {crew, msg_counter, watcher}=state) do
        rcpt = Enum.random(crew) ## recipient of the msg
        if Process.alive?(rcpt) do
            IO.inspect({self(),rcpt}, label: "send message from/to")
            rcv_msg(rcpt, "ChitChat")
            send_msg(self())
            {:noreply, state}
        else
        IO.inspect(rcpt, label: "recipient is dead:")
        {:noreply, {crew -- [rcpt], msg_counter, watcher}}
        end
    end
end


defmodule GossipWatcher do
    use GenServer

    def start_link(opt \\ []), do: GenServer.start_link(__MODULE__, opt)
    def init(opt), do: {:ok, {0}}
    def increase(pid), do: GenServer.cast(pid, {:increase})  
    def handle_cast({:increase}, {counter}), do:
        IO.inspect({:noreply, {counter+1}}, label: "toll of dead")

end

Я использую модуль GossipWatcher, чтобы отслеживать количество погибших GenServer после получения 10 сообщений.Проблема заключается в том, что ответ iex возвращается, тогда как еще есть GenServers в живых .Например, за 1000 GenServer в конце сплетни умирает только ~ 964 GenServers. 

iex(15)> {:ok, watcher} = GossipWatcher.start_link
{:ok, #PID<0.11163.0>}
iex(16)> Gossip.launch 100, watcher            
send message from/to: {#PID<0.11165.0>, #PID<0.11246.0>}
:ok     
send message from/to: {#PID<0.11165.0>, #PID<0.11167.0>}
send message from/to: {#PID<0.11246.0>, #PID<0.11182.0>}
send message from/to: {#PID<0.11165.0>, #PID<0.11217.0>}
...
toll of dead: {:noreply, {960}}
toll of dead: {:noreply, {961}}
toll of dead: {:noreply, {962}}
toll of dead: {:noreply, {963}}
toll of dead: {:noreply, {964}}
iex(17)>

Я что-то здесь упускаю?Время процесса истекло?Любая помощь будет оценена
TIA.

1 Ответ

0 голосов
/ 02 октября 2018

Часть вашего кода, которая может играть некоторые трюки, находится здесь: 

def handle_cast({:send_periodic_message}, zero_counter_gossip_true) do

    ...

    if (Process.alive?(rcpt)) == true do

    ...

    else
        IO.inspect(rcpt, label: "recipient is dead:")
        {:noreply, {crew -- [rcpt], msg_counter, watcher}}
    end
end

В этой части остального вы разрешаете GenServer перестать работать : так какне отправляет сообщение соседу или самому себе, «действие» не запускается, и оно просто прекращает что-либо делать.
В худшем и маловероятном случае: если вы запускаете 2000 GenServer и запускаете сплетни с одного GenServer и что этот первый говорит только со вторым, который также говорит только с первым .... тогда только один GenServer умрет, и вы вернетесь в командную строку с 1999 GenServerжив, но ничего не делает (так как они получают 0 сообщений).

Даже если этот случай далеко уловлен, это показывает, что выполнение сплетни может закончиться преждевременно до того, как каждый GenServer получит 10 сообщений.Отсюда и поведение, которое вы описываете.

Я провел некоторый тест, переписал ваш код и использовал второй тип GenServer для отслеживания количества GenServers убитых, исколько выживет.Оказывается, из 1000 GenServers я получаю в среднем 40 GenServer, все еще живых после того, как я получил приглашение iex.

...