Ответ 1

Используя ваши сущности, я подтвердил, что эта проблема может быть воспроизведена в MRI 2.2.1, а также jRuby 1.7.21 и Rubinius 2.5.8... Разница между server1.rb и server2.rb заключается в использовании DisplayMessage и message метод класса в последнем.

Использование sleep в DisplayMessage вне области Celluloid.

Когда sleep используется в server1.rb, он использует Celluloid.sleep в действительности, но при использовании в server2.rb используется Kernel.sleep... который блокирует почтовый ящик для Server до 60 секунд Прошло. Это предотвращает будущие вызовы метода для того, чтобы этот субъект обрабатывался до тех пор, пока почтовый ящик не обработает сообщения (вызовы методов для актера) еще раз.

Существует три способа решения этой проблемы:

• Используйте блок defer {} или future {}.

• Явно вызывать Celluloid.sleep, а не sleep (если явно не вызываться как Celluloid.sleep, использование sleep будет end the call Kernel.sleep, так как DisplayMessage не include Celluloid как Server делает)

• Принесите содержимое DisplayMessage.message в handle_message, как в server1.rb; или, по крайней мере, в Server, который находится в области Celluloid, и будет использовать правильную sleep.

Подход defer {}:

def handle_message(message)
  defer {
    DisplayMessage.message(message)
  }
end

Подход Celluloid.sleep:

class DisplayMessage
    def self.message(message)
      #de ...
      Celluloid.sleep 60
    end
end

Не совсем вопрос о масштабах; это об асинхронности.

Повторяю, более глубокая проблема не в области sleep... поэтому defer и future - моя лучшая рекомендация. Но публиковать что-то здесь, что вышло в моих комментариях:

Использование defer или future вызывает задачу, которая заставит актера привязаться к другому потоку. Если вы используете future, вы можете получить возвращаемое значение после выполнения задачи, если вы используете defer, вы можете запускать и забывать.

Но еще лучше, создайте другого актера для задач, которые, как правило, связаны друг с другом, и даже пускают этот другой актер... если defer или future не работают для вас.

Я был бы более чем счастлив ответить на последующие вопросы, поднятые этим вопросом; у нас есть очень активный активный список рассылки и канал IRC. Ваши щедрые щедрости заслуживают похвалы, но многие из нас помогут вам просто помочь.

Ответ 2

<суб > Удалось воспроизвести и устранить проблему. Удаление моего предыдущего ответа. По-видимому, проблема кроется в sleep. Подтверждено добавлением журналов "actor/kernel sleeping" в локальную копию Celluloids.rb sleep(). Суб >

В server1.rb,

вызов sleep находится внутри server - класса, который включает в себя Celluloid.

Таким образом, реализация целлулоида sleep переопределяет нативный sleep.

class Server
  include Celluloid::ZMQ

  ...

  def run
    loop { async.handle_message @socket.read }
  end

  def handle_message(message)

        ...

        sleep 60
  end
end

_{Обратите внимание на журнал actor sleeping из server1.rb. Журнал добавлен в Celluloids.rb sleep()}

Это приостанавливает только текущий "актер" в Целлулоиде то есть только текущая "целлулоидная нить", обрабатывающая клиент1, спит.

В server2.rb,

вызов sleep находится в пределах другого класса DisplayMessage, который не включает Celluloid.

Таким образом, это собственный нативный sleep.

class DisplayMessage
    def self.message(message)

           ...

           sleep 60
    end
end

_{Обратите внимание на ОТСУТСТВИЕ любого журнала actor sleeping из server2.rb.}

Это приостанавливает текущую рубиновую задачу, то есть рубиновый сервер засыпает (а не только одного актера Целлулоида).

Исправление?

В server2.rb соответствующий адрес sleep должен быть явно указан.

class DisplayMessage
    def self.message(message)
        puts "Received at #{Time.now.strftime('%I:%M:%S %p')} and message is #{message}"
        ## Intentionally added sleep to test whether Celluloid block the main process for 60 seconds or not.
        if message == 'client-1'
           puts 'Going to sleep now'.red

           # "sleep 60" will invoke the native sleep.
           # Use Celluloid.sleep to support concurrent execution
           Celluloid.sleep 60
        end
    end
end