c++ - boost::asio::strand && boost::lockfree::spsc

c++ - boost::asio::strand && boost::lockfree::spsc_queue

转载作者：行者123 更新时间：2023-11-30 05:12:59

25

4

如果我正在运行一个带有线程池的 boost::asio::io_service 并使用 boost::asio::strand 包装一个特定的套接字接收模拟单线程操作，有谁知道 strand 是否满足安全生产到 boost::lockfree::spsc_queue 的要求，即使我将从不同线程生产但保证一次只生产一个。

最佳答案

是的。通过链进行序列化可以保证您所追求的。稍微扩展一下，如果您有多个支架(例如，对于多个套接字)——那么在推送到同一队列的多个链之间不存在这样的保证。

关于c++ - boost::asio::strand && boost::lockfree::spsc_queue，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/44182758/

25

4

0

文章推荐： android - 如何从 RecyclerView 清除数据监听器/订阅？

文章推荐： c++ - 重复常量 c_strings 是否重复？

文章推荐： java - 为什么Hibernate会忽略@Column注解的name属性？

c++ - 为什么没有 strand::wrap() 等同于 strand::post()？
strand::wrap() 的行为被定义为它创建一个仿函数，该仿函数将在调用时执行 strand::dispatch()。我最近在我们的一个执行以下序列的应用程序中遇到了一个错误: my_great
c++ - strand.post 和 strand.wrap 的性能区别是什么？
strand::post() 和 strand::wrap() 之间的性能差异是什么？使用 strand::wrap() 时关于竞争条件的故事是什么？最佳答案只是为了澄清，strand::wrap
c++ - 如何检测处理程序是否为 ASIO strand wrap 并通过 strand 调用它？
如果有一个通用方法接受一些处理程序: template void Register( HandlerType && handler ) { m_handler( std::forward( h
c++ - asio::strand 与 io_context::strand
由于最新版本的 boost，asio 推出了新的执行器并提供了 asio::strand .所以现在完全可以使用 asio::strand而不是 io_context::strand .但它们不能互换
c++ - asio::strand 的拷贝是否会创建一个新的执行程序？
我有一份 asio::io_service::strand . 复制的链及其源是不同的执行者吗？换句话说，传递给复制链的函数和传递给源链的另一个函数是否可能由两个不同的线程同时执行？或者这两个分支在
c++ - asio strand 对象线程安全吗？
我必须开发一个与服务器对话的异步客户端。客户端在与主应用程序不同的线程中运行，并使用回调链读取服务器发送的内容。每个读取处理程序通过一个链注册下一个(它有点复杂，因为我使用类方法作为回调，所以我需要绑
multithreading - ASIO strand::wrap 不是必须按顺序序列化吗？
我对使用 strand::wrap 和 strand::post 发帖之间的区别感到迷惑不解？似乎两者都保证序列化，但是如何使用 wrap 序列化而不获得一致的顺序？似乎他们都必须做同样的事情。我什么
c++ - boost::strand 生产者/消费者有意义吗？
在this blog post (2010) ，有人试图使用 Boost::strand 工具解决生产者/消费者问题。我感觉他没有捕获要点，他的程序从来没有同时运行一些生产者和一些消费者，但我不是 b
c++ - 澄清在 boost::strand 中执行的内容
我有一个关于什么在 strand 中运行，什么不运行的问题。我已经阅读了关于 SO 的帖子以及 strand 的文档，但我想确保我已经正确理解了它与下面代码的关系。下面的类是一个 tcp 客户端，它
c++ - 将 boost::strand 包装的处理程序存储在数组中
我正在尝试将一些事件处理程序存储在数组中。其中一些被 boost::strand::wrap 包裹。 boost::function proc_handlers[] = { boost::bi
c++ - 我需要在此服务器模型中使用 boost::strand 吗？
我编写此服务器代码已有一段时间了。我从超过 1 个线程调用 io_service::run，但我不确定我是否需要在这里使用 strand。因为我从不多次调用 async_read 。如果其他连接需要向
c++ - asio::io_service::strand 的正确用法？
这是我的代码: void client_connection::serve() { asio::async_read(this->socket_, asio::buffer(&buffer_,
c++ - 即使使用 strand，async_writes 的顺序也不正确
我正在编写一个程序，将读取的数据转发给另一个对等点。我有一个在每次读取套接字上的数据后调用的方法。此方法将数据发布到一个链中以将其写回另一个对等点。当发送大块数据时，应用程序发回的数据与接收到的数据不
c++ - boost::asio strand 包裹的线程不能立即工作
我最近使用了 boost::asio::strand。我对此没有经验。如果我用 strand::wrap() 调用 function1 并用调用 function2 ，我遇到了什么~functio
c++ - 如何运行时检查代码是否由给定的 asio::strand 实例保护
我想在我的代码中添加一个运行时断言，以检查代码是否受到给定链的保护。这是一个伪例子: ... asio::io_service my_io_service; asio::strand my_stra
c++ - 我什么时候必须使用 boost::asio:strand
看了boost::asio的文档，还是不清楚什么时候需要用asio::strand。假设我有一个使用 io_service 的线程，那么按如下方式在套接字上写入是否安全？ void Connectio
c++ - boost::asio: "strand"类型的同步原语有什么名字吗？
boost::asio 库提供了一个有趣的同步模型，使用“strands”来序列化对通常需要锁的资源的访问。这实际上通过将每个锁定操作转变为入队来 boost 并行性。搜索“strands”只会产生
c++ - asio::async_write 和 strand
asio::async_write(m_socket, asio::buffer(buf, bytes), custom_alloc(m_strand.wrap(cus
c++ - ASIO 正确处理多线程 + strand + socket + timer
我使用的是最新的 ASIO 版本(目前为 1.18.0)。目前正在设计一个带有定时器(用于超时)的多线程异步 TCP 服务器。我有一个 io_context 有多个线程调用它的 run() 函数。我接
javascript - 我们怎么称呼 JS async "strands of execution"？
在 Java 中我们有“线程”，在 CPython 中我们有线程(非并发)和“进程”。在 JS 中，当我启动一个 async 函数或方法时，我如何正式引用这些“执行代码链”？我听说每个这样的代码块

首页

博学

6Ren·AI

商城

c++ - boost::asio::strand && boost::lockfree::spsc_queue