- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
boost::shared_ptr<A> a = boost::shared_ptr<A>(new A);
a->i = 2;
strand.post([a](){assert(a->i == 2)});
或
io_service.post([a](){assert(a->i == 2)});
当我将处理程序发布到线程 1 中的 strand 或 io_service 时,执行处理程序的线程 2 是否在发布之前看到数据更改?
Java 有类似的东西 Executor 可以建立 happen-before 关系:
Actions in a thread prior to the submission of a Runnable to an Executor happen-before its execution begins. Similarly for Callables submitted to an ExecutorService.
asio 呢?
请注意,此问题不会询问发布到 io_service 或 strand 的处理程序的执行顺序。 Asio doc说如果使用 strand,post(a) happen-before post(b)。但是这个问题问:在(编码顺序)post(a)之前的 Action 是否发生在 post(a)(处理程序 a 的执行)之前?这是关于内存模型的。让我澄清一下:
// in thread1
global variable a = 111;
start a new thread2 which will access global variable a
我们知道线程 1 中的操作在线程 2 启动之前发生在线程 2 启动之前。也就是说: 1、最终执行顺序与代码顺序相同(编译器或CPU不会改变顺序)。 2、global variable a
value set action会刷新到主内存(或者同步到thread2的CPU cache),然后thread2会更新到global variable a
的最新值(当然, 直到它开始)。
asio的帖子和这个例子类似,所以我问这个问题。我觉得asio的帖子应该make happen-before关系,不然就没用了。但是我不确定,我想知道 asio 是怎么做到的。
要让happen-before,有3种方式:1,线程启动,加入。 2、锁定和解锁互斥体。 3、内存障碍。
最佳答案
以下所有对象在内存排序上都存在先行关系:io_service::post()
、io_service::dispatch()
、strand: :post()
和 strand::dispatch()
。这主要是 io_service
和 strand
为单个对象可以并发使用提供强有力保证的结果。在这种不需要潜在阻塞同步的情况下,例如当发布到 dispatch()
的处理程序可能在 dispatch()
函数的上下文中执行时,则full memory fence已发行。
documentation注意使用内存屏障进行处理程序分配:
[...] The implementation will insert appropriate memory barriers to ensure correct memory visibility should allocation functions need to be called from different threads.
关于c++ - asio::io_service::post 是否使关系发生在发生之前?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32065068/
我有一个 ip::udp::socket用 io_service 构建.只有一个 boost::thread调用 io_service::run()方法,以及 io_service::work 的一个
我为异步 io_service 工作运行 aync 作业线程。 我想销毁用于异步作业的资源。 boost::asio::io_service boost::asio::io_service::work
我有一个 boost::asio 线程池,它有一个 asio::io_service和 asio::work : boost::asio::io_service m_service; boost::a
我正在编写多线程 TCP 服务器,基于应用程序设计,我需要有多个线程,每个线程都有 io_service。 通过该设计,我需要接受来自一个Thread/io_service 的连接,进行身份验证过程(
如果我io_service::run()只在一个线程中运行,那么io_service::post()调用是在我要求它们执行的顺序相同,或者它们可以按任意顺序执行,我仍然需要使用 strand 来强制序
boost::asio::io_service m_io_service; boost::asio::io_service::work m_work(m_io_service); m_io_servi
长话短说,我的代码: #include #include #include #include #include #include namespace ba = boost::asio; n
我的简化问题 我阅读了this thread,并试图删除io_service对象。我做这个 m_IO.stop(); m_IO.~io_service(); m_IO是boost::asio::io_
我使用 boost::asio::io_service 来处理 Foo 中的工作。现在它工作正常,直到我退出 ~Foo 并卡在 io_service 析构函数(在 service_registry 的
我想在里面的类中周期性地制作一个10秒的计时器,但是它不起作用。它会在 10 秒内第一次打印计数。但在那之后,它不会再等待 10 秒。具体代码。 #include #include #includ
我正在尝试运行 udp 服务器。问题是阻塞了 io_service 上的 run() 调用。所以我决定使用 boost bind 在其他线程上运行这个方法。结果主线程执行超出了 DictionaryI
我一直在阅读 boost asio 文档,特别是关于 Proactor 设计的。 当我看到这个标题的时候 前摄器设计模式:无线程的并发 我的理解是,asio 的用户不需要创建额外的线程来执行异步 IO
我想让程序等到它完成所有正在运行的线程,这与 ioService.stop(); 不同,后者无需等待即可停止 ioService。我尝试了以下代码,它工作正常,但没有等待线程完成就停止了 ioServ
为什么在这个简单的类中,如果我直接使用 io.run() 函数将被调用,否则如果要求运行到其他线程,打印将不会被调用? #include #include #include using name
正在尝试学习 asio,我正在关注网站上的示例。 为什么需要 io_service 以及它的具体作用是什么?为什么我在执行异步操作时需要将它发送到几乎所有其他函数,为什么它不能在第一次“绑定(bind
我正在使用boost::io_service构建并行执行计算作业的线程池。有些作业不允许同时运行,我认为这是boost::io_service::strand的理想应用。作为,执行顺序作业的顺序与无关
我正在编写一个网关服务,它监听网络套接字并将接收到的数据包路由到单独的守护进程。我打算使用 boost asio,但我遇到了几个问题。这是我计划实现的服务器的设计: 网关将使用 boost asio
我正在尝试实现一个包含两个处理循环的 C++ 应用程序。当前,第一个处理循环(boost 的 io_service::run)阻止了第二个处理循环的执行。 利用线程或 std::async 方法的方法
我正在尝试学习 io_service 并使用共享指针。我希望代码无限地工作,直到我像这样调用 stop 方法或某事。不幸的是,在屏幕上看到 workHandler 的输出后,程序关闭了。任何人都可以解
我更喜欢使用 io_service 的方式是在应用程序启动时创建一个线程来执行 io_service的运行方法。问题是,如果 io_service 没有任务,它的 run 方法立即返回并且线程终止。
我是一名优秀的程序员,十分优秀!