Шаблон для фонового сервера Twisted, который заполняет очередь входящих сообщений и очищает очередь исходящих сообщений?

Я бы хотел сделать что-то вроде этого:

twistedServer.start() # This would be a nonblocking call

while True:
   while twistedServer.haveMessage():
      message = twistedServer.getMessage()
      response = handleMessage(message)
      twistedServer.sendResponse(response)
   doSomeOtherLogic()

Главное, что я хочу сделать запускается сервер в фоновом потоке. Я надеюсь сделать это с помощью потока, а не с помощью многопроцессорной обработки / очереди, потому что у меня уже есть один уровень обмена сообщениями для моего приложения, и я бы хотел избежать двух. Я поднимаю этот вопрос, потому что уже вижу, как это сделать в отдельном процессе, но я хотел бы знать, как это сделать в потоке или могу ли я. Или, если, возможно, есть какой-то другой шаблон, который я могу использовать, который выполняет то же самое, например, написание моего собственного метода response.run. Спасибо за любую помощь. :)

5
задан shino 12 November 2010 в 03:34
поделиться