Хочу уточнить как работает асинхронный ввод вывод

Привет!

Посмотрел видос, где рассказывается про асинхронный ввод вывод на примере сокета. Рассказывается это на примере C++ под Linux-ом. Но я не совсем понял один из принципов работы этого дела. Интересует не сколько работа в контексте С++, сколько принцип работы на уровне ОС. В двух словах перескажу суть как я её понял.

Итак, вызываем на сокете условный метод (далее везде будет псевдокод):
В этот момент где-то внутри операционной системы регистрируется, что я хочу получать уведомление если от это конкретного сокета прийдет конкретное событие accept. Когда такое случается информация об этом добавляется в специальную_очередь, обработку которой инициирует конкретный фреймворк, в результате чего вызывается указанный callback, в данном случае это accept_callback.

После того, как вызвался accept_callback я в нем делаю что-то вроде
При этом где-то в операционной системе регистрируется информация о том, что я хочу получать уведомления когда по указанному сокету придет событие read. Когда из сокета что-то считалось, информация об этом снова попадает в специальную_очередь из которой потом попадает в мое приложение в read_callback .

Внутри read_callback я снова могу сделать
если хочу снова получить уведомление о том, что из сокета что-то пришло.

Вопрос следующий. Вот у меня суть метода accept_callback:
Если до момента socket.read_async(read_callback) из сокета что-то считалось, то в специальной_очереди информация об этом не зарегистрируется? То есть если я не успел зарегистрировать событие до того, как оно произошло, я об этом уже не узнаю или узнаю все таки?

0

Актуально

0

V0fka, а конкретнее если? Что вы понимаете под "специальной очередью"?

0

Что бы не быть испорченным телефоном, вот видео о котором речь: https://youtu.be/CBM2K0qdmOg?l... c_fT&t=730 (с этого момента начинается рассказ про асинхронность). Через минуту на 13:15 чувак рисует очередь и рассказывает что это.

0

V0fka, операционная система не знает ничего о callback`ах. Callback вызывает фреймворк в ответ на событие на сокете. Если вы заранее делаете чтение, то снимаете событие с сокета. Следовательно, функция фреймворка, ожидающая события на сокете, не сможет реагировать на них (путем вызова callback`ов) до тех пор, пока не придут новые данные.

0

Сообщение от DrOffset Callback вызывает фреймворк в ответ на событие на сокете

Если событие пришло до того, как я успел на него подписаться, я получу уведомление об этом событии или оно для меня потеряно? То есть если я говорю "читать" после того, как данные на сокет уже пришли.

0

Сообщение от V0fka То есть если я говорю "читать" после того, как данные на сокет уже пришли.

Если данные пришли и еще не были прочитаны и вы говорите "читать", то уведомление вы получите.

1

Сообщение от DrOffset Если данные пришли и еще не были прочитаны и вы говорите "читать", то уведомление вы получите.

А как это реализуется? Система же не знает скажу я "читать" или не скажу. Интересен именно принцип того, как это работает.

0

Сообщение от V0fka Система же не знает скажу я "читать" или не скажу.

Система знает есть данные или нет. Если данные есть, и вы мониторите (или фреймворк мониторит) их наличие, то можно будет как-то на это реагировать. Мониторинг наличия данных включается как раз функциями наподобие read_async.

0

Сообщение от DrOffset Система знает есть данные или нет.

При этом они же должны где-то храниться, если система может их отдать когда её попросят? Попробую по другому вопрос сформулировать. Например, есть какой-то поток данных, скажем в 100 Мб. Начинают они попадать в сокет: 1 байт, 2 байта ... 1 мегабайт, 99 Мбайт. На 99-м мегабайте я говорю read_async. При этом я получу все эти 99 Мб, которые были посланы ранее? А если поток данных будет в 100 Гб? Суть вопроса, надеюсь, понятна.

0

Сообщение от V0fka они же должны где-то храниться, если система может их отдать когда её попросят?

Да, они хранятся.

Сообщение от V0fka При этом я получу все эти 99 Мб, которые были посланы ранее?

Скорее всего не получите. Это зависит от размеров системных буферов. За размер получаемых данных отвечают опция SO_RCVBUF, которую можно установить через системный вызов setsockopt. Устанавливаемое таким образом значение не может быть больше системной переменной rmem_max, по-умолчанию ее значение 128КБ (или около этого значения).

Сообщение от V0fka Суть вопроса, надеюсь, понятна.

Ну, так получается, что тогда асинхронный io тут не при чем, а вопрос, скорее, о вместимости системных буферов для получаемых данных.

1

Сообщение от DrOffset Ну, так получается, что тогда асинхронный io тут не при чем, а вопрос, скорее, о вместимости системных буферов для получаемых данных.

Ну может оно и не совсем причем, но я об этом задумался именно в контексте размышлений про асинхронный IO. Не могу сказать, что я все обо всем понял, но какую-то пищу для размышлений я получил. Спасибо вам за ответы!

0