Bezdepbonusu7Программирование: статьи и ответы
Меню

Вопрос

Многопоточный сервер с boost asio

Автор вопроса: markОтветов: 1

Я рассматриваю возможность написания многопоточного TCP-сервера с использованием Boost ASIO. Я прочитал учебные пособия и просмотрел некоторые примеры и просто хочу проверить правильность моего понимания.

Сервер будет принимать соединения, а затем обслуживать запросы от нескольких клиентов.

Мое понимание заключается в следующем:

  1. Сервер использует "один io_service и пул потоков, вызывающий io_service::run()"
  2. Все потоки вызывают io_service::run().
  3. Вызовы io_service::run() не находятся внутри нити, поэтому обработчики завершения могут работать одновременно.
  4. При поступлении запроса выбирается один из потоков, вызывается его обработчик чтения
  5. Может поступить другой запрос, запускающий обработчик чтения во втором потоке.
  6. Когда один из потоков завершает обработку запроса, он вызывает async_write из strand
  7. Другой поток также завершает обработку своего запроса, он также вызывает async_write из цепочки.
  8. Записи в io_service сериализуются через strand, поэтому они потокобезопасны.
  9. Когда операция записи завершается, поток вызывает async_read()
  10. Этот вызов не защищен strand, и поток будет использоваться для обработки запросов.

Правильно ли я понимаю? Уязвимо ли это решение к условиям гонки?

  • Это действительно не ответ на вопрос, поскольку он в настоящее время написан. В вашем понимании нет ничего неправильного. У вас есть конкретные проблемы? Если да, можете ли вы опубликовать код? Sam Miller 15.01.2012
  • Я просто хотел подтвердить, что мои предположения/понимание верны, прежде чем идти дальше и реализовывать его. Я думаю, что вы, возможно, сделали это, спасибо. У меня был только ограниченный опыт asio в oast, и я впервые планирую использовать его в гневе. mark 15.01.2012
  • @mark ты написал этот сервер? Я просмотрел несколько примеров многопоточных асинхронных серверов, но для меня это накладные расходы. Не могли бы вы показать свой? Alex 28.08.2012

c++boostboost-asio

Ответы

Ответ 1 · рейтинг 3 · TheSquad

Как сказал Сэм Миллер, ваши предположения вполне верны.

Однако я хотел бы указать на проблему, которую вы, возможно, не заметили.

Это правильно, что пряди будут сериализовать async_write(s) и, следовательно, будут потокобезопасными. Но проблема не здесь, async_write сам по себе потокобезопасен, если не используется в том же сокете. И strands тут не помогут, так как не стоит чередовать async_write на одном сокете.

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

Перевод вопроса и ответов сообщества Stack Overflow, лицензия CC BY-SA. Оригинал на Stack Overflow.

Похожие материалы