Я бы хотел сделать что-то вроде этого:
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. Спасибо за любую помощь. :)