Сокеты C ++ Send () Потоковая безопасность

Обычная схема работы со многими сокетами - это иметь специальный опрос потока для событий ввода-вывода с помощью select(2) , poll(2) или лучше _ 3_ или _ 4_ (в зависимости от платформы), действующий как диспетчер событий сокета. Сокеты обычно обрабатываются в неблокирующем режиме. Тогда у вас может быть пул потоков, реагирующих на события, которые либо выполняют чтение и запись напрямую, либо через буферы / очереди более низкого уровня.

Здесь применимы всевозможные техники - от очередей до досок подписки на мероприятия. Становится сложнее с мультиплексированием, принимает / читает / записывает / EOF на уровне ввода-вывода и с арбитражем событий на уровне приложения. Несколько библиотек, например libevent и _ 6_ поможет структурировать нижний уровень (библиотека ACE также находится в этом месте, но я бы не хотел рекомендовать ее кому-либо ). Вам придется самостоятельно создавать протоколы уровня приложений и конечные автоматы (опять же _ 7_ может помочь).

Несколько хороших ссылок, чтобы лучше понять, с чем вы сталкиваетесь (вероятно, это миллионный раз, когда они упоминаются здесь, на SO):

• Проблема C10K
• Архитектура высокопроизводительного сервера

Приносим извинения за то, что не предложили конкретного решения, но это очень широкий вопрос дизайна, и большинство решений во многом зависят от контекста (хотя и весело). Надеюсь, что это помогает немного.

Поскольку вы отправляете данные через разные сокеты, проблем быть не должно. Когда эти разные потоки обращаются к одним и тем же данным, вы должны обеспечить их целостность.

Вы используете сокеты UDP или TCP?

В случае UDP каждая запись должна быть инкапсулирована в отдельный пакет и передаваться на другую сторону в неизменном виде. Порядок можно поменять местами (как и для любого пакета UDP), но они должны быть целыми.

Если TCP, то нет концепции пакетов на транспортном уровне, и любые 10 записей на одной стороне могут быть объединены на другой стороне за одно чтение. Запись TCP также может принимать только часть вашего буфера, поэтому, даже если функция send () является атомарной, ваша запись не обязательно. В этом случае вам нужно будет его синхронизировать.

send () не является атомарным в большинстве реализаций, поэтому отправка в 1000 разных сокетов из нескольких потоков может привести к получению смешанных сообщений на стороне клиента и всевозможным странностям. (I ничего не знаю, см. комментарии Николая и Роберта ниже, остальная часть моего комментария все еще в силе (с точки зрения решения вашей проблемы))

Я бы использовал потоки для отправки, как вы используете их для получения. Один поток для управления отправкой в ​​один (или несколько) сокетов, который гарантирует, что вы не будете писать в один сокет из нескольких потоков одновременно.

Также см. здесь дополнительное обсуждение и другие интересные ссылки. Если вы работаете в Windows, часто задаваемые вопросы о программистах winsock является бесценным ресурсом. Для решения вашей проблемы см. здесь.