Надежно ли boost :: io_service :: post thread?

Question

Безопасно ли публиковать новые обработчики из обработчика?Т.е. могут ли потоки, которые вызывали io_service::run(), отправлять новые обработчики на тот же io_service?

Answer 1

безопасно отправлять обработчики из обработчика для одного экземпляра io_service в соответствии с документацией.

Thread Thread

Отдельные объекты : Безопасный.

Общие объекты : Безопасный, за исключением того, что вызывает reset (), пока есть незавершенные run (), run_one (), poll () или poll_one () вызывает неопределенное поведение.

Answer 2

Я думаю, что это не потому, что следующий код не вернул 3000000, и я не видел мьютекса, синхронизирующего внутреннюю очередь io_service, ни очереди без блокировки.

#include <boost/asio/io_service.hpp>
#include <boost/thread.hpp>
#include <boost/thread/detail/thread_group.hpp>
#include <memory>

void postInc(boost::asio::io_service *service, std::atomic_int *counter) {
  for(int i = 0; i < 100000; i++) service->post([counter] { (*counter)++; });
}

int main(int argc, char **argv)
{
  std::atomic_int counter(0);

  {
    boost::asio::io_service service;
    boost::asio::io_service::work working(service);
    boost::thread_group workers;

    for(size_t i = 0; i < 10;++i)     workers.create_thread(boost::bind(&boost::asio::io_service::run, &service));

    boost::thread_group producers;
    for (int it = 0; it < 30; it++)
    {
      producers.add_thread(new boost::thread(boost::bind(postInc,&service,&counter)));
    }

    producers.join_all();
    std::cout << "producers ended" << std::endl;

    service.stop();
    workers.join_all();
  }

  std::cout << counter.load();

  char c; std::cin >> c;
  return 0;
}