Использование API блокировки Mysql с Boost :: asio

Question

Я создаю однопоточный сервер aync, который получает данные от клиентов. Он обрабатывает данные, а затем сохраняет их в базе данных MySQL.

Проблема заключается в том, что MySQL C API не поддерживает неблокирующие вызовы, а asio в основном не любит блокировки вызовов.

Так что я думаю что-то вроде deferToThread() Python Twisted, как семантика. Кто-нибудь, кто уже развил такую ​​вещь? Или я должен его реализовать?

Answer 1

Был a post в список рассылки Asio в течение лета, описывающий общий асинхронный класс обслуживания, который кажется им может быть полезен для вас. Этот псевдо-код от электронной почты автора я связан:

// Create a command processor with 5 threads allocated 
// to processing the commands. 
async_command_processor processor(io_service, 5); 

// Execute the command asynchronously and call the 
// MyCommandComplete callback when completed. 
processor.async_execute(MyCommand, MyCommandComplete); 

Answer 2

"огонь и забыть" нить. Вы можете создать класс с операторами() и переменными-членами с данными для записи. В обработчике данных asio accept создайте один из этих классов, а затем передайте его в поток boost. Boost thread будет КОПИРОВАТЬ этот класс внутри и запустить поток. Если вы внимательно относитесь к тому, как вы пишете оператор(), он должен завершиться, когда запись sql будет выполнена и выпустить свои данные записи. Вы можете вызвать boost :: thread :: detach, чтобы забыть о потоке и просто дать ему закончить, а затем умереть. Таким образом вы запускаете новые потоки, которые пишут mysql из ваших обработчиков asio. Я не уверен, что происходит с данными элемента, когда класс потока выходит за рамки. дважды проверьте документы повышения, может быть проблемой, если поток повышения не завершен, и поток по-прежнему нуждается в данных, которые исчезли. Возможно, здесь могут помочь общие указатели.

Answer 3

Может быть, вы будете заинтересованы в этом на основе Asio асинхронного клиента библиотеки MySQL с именем Amy: https://github.com/liancheng/amy

Цитируется GitHub README:

Amy является совместимым с C++ 11 только заголовком A synchronous My SQL-клиентская библиотека на основе Boost.Asio. Это позволяет работать с MySQL как асинхронным, так и блокирующим способом.