Всем привет, мучаюсь с архитектурой многопоточного сервера.
Я пишу сервер для игрушки на ThreadRemotingServer. Есть куча потоков в которых крутятся AsyncProxy, они слушают сокеты клиентов. И есть центральный объект с моделью мира, в своём потоке. Предположим, центральному объекту понадобилось отправить потоковое сообщение одному из прокси. Я вызываю thread.sendMessate(), но ведь прокси заблокирован, потому что ждёт сообщение от сокета. Т.е. у него будет шанс прочитать это сообщение только когда что-нибудь придет из сокета и он отомрёт. Как быть? Сделать как-нибудь прокси неблокирующими и завести в них таймер, по которому будут проверяться сообщения и от сокета и мешпотоковые? Это как-то некрасиво.

Никогда не писал многопоточные сервера, грамотные люди, расскажите как вы делаете.
Спасибо.