Зачем использовать writefds в select? Как их использовать на практике?

Question

Я разрабатываю программу C в Linux, где у меня будет два потока. Один основной поток - event_processor_thread, который выполняет основную обработку функции. Второй поток - поток event_dispatcher, всегда работающий в фоновом режиме, запись и считывание с нескольких интерфейсов в реальном времени (без блокировки async i/o)

Я провел некоторое исследование в сети и нашел, что лучшие способы реализации неблокирующая разъем ввода/вывода может быть достигнуто с помощью

1. libevent
2. select()

Я выбрал последнее, так как его легче, и я буду иметь на границах наиболее 4 считываемых из/сог это к.

Понятно, что механизмы прослушивания/чтения используются с использованием readfds, но я не уверен, как использовать writefds! Если я поместил свои данные из event_processor_thread в разделяемую память и попросил этот поток диспетчера событий прочитать это из разделяемой памяти и написать с помощью send(), выберете сами позаботиться о передаче данных в сокет? Вот почему мне нужно использовать writefds в select()?

Приносим извинения, если мои вопросы не ясны, то, что я в основном хочу, это иметь неблокирующий поток ввода-вывода для отправки событий в/из потока процессора событий во внешний интерфейс. Любые материалы в этом отношении высоко оценены. Благодаря!

Answer 1

Нет, select() не будет «заботиться о письме». Он уведомит вас, когда один или несколько дескрипторов файлов, включенных в набор writefds, станут доступными для записи. Это может означать, что рассматриваемые fd (s) завершили предыдущую (неблокирующую) запись, которую вы сделали, чтобы теперь вы могли сделать другую.

Answer 2

Запись в формате write - это проверка того, что дескриптор файла готов для записи. Для сокета это означает, что буфер отправки, связанный с сокетом, не заполнен.

Предположим, что сокеты на вашей платформе имеют буфер 8 килобайт и вы хотите отправить 100 килобайт данных.

Вы вызываете write и получаете возвращаемое значение 8192, указывающее, что записаны первые 8192 байта. Следующий вызов для записи возвращает либо EAGAIN, либо EWOULDBLOCK, указывающий, что буфер отправки заполнен.

Теперь вы можете использовать select, чтобы узнать, когда снова есть место в буфере отправки (т. Е. Когда один клиент tcp/ip был передан клиенту), чтобы вы могли продолжать писать. В то же время вы можете слушать новые подключения и ждать ввода от клиентов.

Обратите внимание, что select никогда не отправляет никаких данных, он просто отслеживает состояние нескольких дескрипторов файлов за один раз.

Answer 3

select() сообщает вам, когда файловый дескриптор доступен для записи. Для сокета это означает, что он может принимать новые исходящие данные без блокировки вызывающего. Если вы вызываете send() или write(), а исходящий буфер сокета заполнен, вы получите ошибку EAGAIN или EWOULDBLOCK, после чего вы прекратите запись в этот сокет до тех пор, пока он не станет перезапущен.select() также может сообщить вам, когда сокет станет доступен для записи после вызова неблокирующего connect(), что указывает на успешное соединение, и данные могут начать записываться в одноранговую сеть.