boost:: IO service как гарантировать последовательность выполнения обработчика

У меня есть пул потоков с boost::io_service сверху. Я использую его для различных задач, связанных с процессором в целом приложении. Для некоторых задач я должен гарантировать, что задачи будут выполняться в указанном порядке (декодирование видеопотока). Использование io_service::strand гарантирует, что задачи не будут выполняться в данный момент, но у него нет никаких гарантий относительно порядка выполнения. Другими словами, задача №5 может быть выполнена до выполнения задачи №4. Существует ли какой-либо метод для решения этой проблемы, кроме планирования следующей задачи после выполнения текущей.

667   1  

1 ответ:

strand обеспечивает гарантию того, что обработчики завершения не будут выполняться одновременно, и определяет порядок вызова обработчика. Короче говоря, обработчики завершения, разнесенные в strand, выполняются в том же порядке, в котором они разнесены.

Следовательно: 

strand_.post(&task1);
strand_.post(&task2);
strand_.post(&task3);

Гарантирует, что порядок вызова обработчика равен task1 -> task2 -> task3. Однако обернутые обработчики завершения для асинхронных операций не гарантированы, так как порядок, в котором выполняются асинхронные операции исполняется неопределенно. Например, следующее не дает такой же гарантии: 

async_read(socket1, ..., strand_.wrap(&task1));
async_read(socket2, ..., strand_.wrap(&task2));
async_read(socket3, ..., strand_.wrap(&task3));

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

  • обработчики завершения очереди и управление заказом вручную.
  • Сериализуйте все асинхронные операции. Например, обработчик завершения async_op_1 task1 инициирует async_op_2 с обработчиком завершения task2.

Вот соответствующий отрывок: из io_service::strand ' s порядок вызова обработчика документация:

Дано:

  • прядильный объект s
  • объект a, удовлетворяющий требованиям обработчика завершения
  • объект a1, являющийся произвольной копией объекта, созданного реализацией
  • объект b, удовлетворяющий требованиям обработчика завершения
  • объект b1, который является произвольной копией b, созданной реализацией

Если какой-либо из справедливы следующие условия:

  • s.post(a) бывает-раньше s.post(b)
  • ...

Затем asio_handler_invoke(a1, &a1) случается-раньше asio_handler_invoke(b1, &b1).

5  
2013-11-13 22:18:03

Comments

    Ничего не найдено.
Click here to cancel reply.