To null56
Для начала смотрим в документацию:
http://www.boost.org/doc/libs/1_55_0/doc/html/boost_asio/overview/core/basics.html
http://www.boost.org/doc/libs/1_55_0/doc/html/boost_asio/overview/core/async.html
| Цитата | | когда мы запускаем socket.async_read, что происходит? |
Код Asio запускает асинхронную операцию средствами ОС (тут же, в этом же методе socket::async_read_some) - в случае, если ОС поддерживает такой вид асинхронных операций, в противном случае Asio эмулирует это (socket::async_connect в Windows). Эмуляция обычно происходит путем добавления новой задачи в свой собственный внутренний пул протоков (может состоять из одного потока).
| Цитата | | имеет ли место в данном случае дополнительный поток (асинхронный процессор), который обрабатывает запрос и передает его ОС? |
Нет, никаких дополнительных потоков в этом месте не создается (за исключением случаев эмуляции - все они описаны в http://www.boost.org/doc/libs/1_55_0/doc/html/boost_asio/overview/implementation.html, Threads). Cчитать io_service "асинхронным процессором" несколько неточно/некорректно.
Вот что сказано в http://www.boost.org/doc/libs/1_55_0/doc/html/boost_asio/overview/core/async.html#boost_asio.overview.core.async.proactor_and_boost_asio:
| Цитата | Asynchronous Operation Processor
Executes asynchronous operations and queues events on a completion event queue when operations complete. From a high-level point of view, services like stream_socket_service are asynchronous operation processors. |
По факту "процессором" выступает сама ОС, ее вызовы встроены в соотв. stream_socket_service и пр. io_service::service. io_service - демультиплексор событий, разгребающий список наступивших событий по мере вызова io_service::run/run_one/poll/poll_one. Видимо, для упрощения (со стороны пользователя Asio) и более тесной интеграции/оптимизации, service-ы, представляющие собой интерфейс для доступа к процессору асинхронных операций встроены в сам io_service.
| Цитата | | далее, скажем, при завершении операции, он формирует сообщение и отправляет его в очередь проактора? |
В общем, да. За исключением того, что в роли проактора выступает сам же io_service.
| Цитата | | а когда мы делаем io_service.run, то уже работаем с цепочкой сформированных событий из нашей нити |
Да (см. http://www.boost.org/doc/libs/1_55_0/doc/html/boost_asio/overview/core/async.html#boost_asio.overview.core.async.proactor_and_boost_asio). Только:- цепочка событий может наполняться еще и за счет io_service::post/dispatch, а не только за счет завершения асинхронных операций.
- на самом деле это не цепочка (не очередь), а предоставляемый ОС механизм демультиплексирования завершенных асинхронных операций (IOCP, epoll, dev/poll, kqueue, select). Вот уже внутри этого механизма ОС может быть и очередь (IOCP - встроенный в ядро ОС проактор).
- кроме механизма демультиплексирования ОС там же может использоваться внутренняя очередь (очереди). Например, так сделано в Asio на Windows (кроме IOCP есть еще отдельная внутренняя очередь для io_service::post/dispatch, которая используется, если IOCP не может быть использован/выдал ошибку/для оптимизации).
- для таймеров иногда (не скажу про все платформы, но на Windows - точно начиная с какой-то версии Boost.Asio, сделано для оптимизации) так же используется отдельный внутренний поток, который ждет наступления таймаута (по отсортированному списку таймаутов) и при наступлении таймаута посылает событие в демультиплексор (возможно, средствами ОС) - вот вам простой пример эмуляции асинхронной операции ожидания.
| Цитата | | то я хотел бы спросить про реализация в системах, где нет асинхронных слежений (select, epoll, и др), как тогда работает асинхронный процессор? |
Эмулируется (см. выше) за счет синхронных операций и внутренних очередей/пулов потоков (отдельных потоков).
To bsa
| Цитата | | происходит постановка задачи "асинхронное чтение из сокета" в очередь |
Разве что в случае эмуляции или же внутри ОС. В других случаях немедленно (в этом же потоке/в этом же методе) стартует асинхронная операция. Это важно - см. нюансы завершения потоков-инициаторов асинхронной операции на сокете и IOCP в Windows.
| Цитата | | Через постоянный опрос состояний в отдельном потоке. Которые генерирует события для потока обработчика. |
Не совсем правильно. Опрос (демультиплексирование) происходит в одном (или во всех - как уж позволяет соотв. механизм ОС - IOCP и epoll тут используются по-разному) из потоков, вызывающих io_service::run/run_one/poll/poll_one[/url]: http://www.boost.org/doc/libs/1_55_0/doc/html/boost_asio/overview/implementation.html |
)
