concurrency 相关问题

我正在 Intel Broadwell XEON 或 AMD EPYC 7551、Intel TBB 和 Pagmo2 库上使用 GCC C++20 编写 C++ 多线程代码以解决优化问题。如果我声明并发向量我正在 Intel Broadwell XEON 或 AMD EPYC 7551、Intel TBB 和 Pagmo2 库上使用 GCC C++20 编写 C++ 多线程代码，以解决优化问题。如果我声明 concurrent_vector<double> X 并且 X 的元素被多个正在运行的线程同时修改，我相信这些操作将是线程安全的。如果我错了，请纠正我。我真正的问题是：如果多个线程访问 X 的元素，即多个线程尝试同时修改 X 的元素，例如X.at(5)，该操作是原子的且无锁的，还是会存在对性能产生重大影响的锁？另外，假设线程 0 修改 X.at(i)，而线程 1 同时使用 X.at(j) 修改 i != j。对性能有何影响？该操作是否是无锁的，即原子操作？我是并发 C++/TBB 新手，无法使用 Google 搜索找到明确、清晰的答案。我已经搜索了Google和TBB文档，但还没有找到上述问题的明确答案。我不确定 TBB 并发容器是否真的是原子的？ ...该操作是否是无锁的，即原子操作？不会有锁，但这并不意味着它的行为像std::atomic concurrent_vector 允许多个线程访问（读、写、取相同元素的地址）。它不会序列化访问，因此这些访问是否安全取决于数据类型。会对性能产生什么影响... tbb::concurrent_vector 通过不移动现有的来解决这个问题调整大小时的存储。相反，为了成长，它创造了一个新的存储块。通过快速恒定时间访问块索引方案。请参阅 tbb/concurrent_vector.h 了解其具体情况已实施。然而，天下没有免费的午餐。并发向量索引与 std::vector 相比，引入了额外的复杂性。因此，如果我建议您不需要同时增长和访问向量使用 std::向量。但是如果你确实有多个线程附加到一个动态增长的数组，那么并发向量可能是一个很好的选择。由于实现的原因，访问元素的性能成本是不可忽略的，这是支持同时增长和访问向量的用例所必需的。注：引用自 https://community.intel.com/t5/Intel-oneAPI-Threading-Building/concurrent-vector-thread-safety/m-p/912060，以获取可能的英特尔员工的答案（因为他们的用户名包含_INTEL）。

c++ vector concurrency atomic tbb

回答 1 投票 0

防止退出/死亡测试

我正在使用 googletest 来使用 std::thread 测试多线程代码。在损坏的代码中，经常会发生 std::thread 在线程加入之前被销毁，从而导致程序终止。

c++ multithreading c++11 concurrency googletest

回答 1 投票 0

嵌套CopyOnWriteArrayList默认是线程安全的吗？

假设我有以下代码：类A类{ 最终整数 i；最终字符串；最终 CopyOnWriteArrayList l; A 类() { ... } } 类 B 类 { 最后在...

java concurrency

回答 1 投票 0

消息驱动通道适配器 - 消息并发处理

问题我们有一个具有以下消息驱动通道适配器配置的遗留应用程序问题我们有一个具有以下消息驱动通道适配器配置的旧应用程序 <jms:message-driven-channel-adapter id="processRequest" destination="requestFromLoader" connection-factory="connectionFactory" max-concurrent-consumers="30" message-converter="xmlMarshalConverter" channel="jmsInChannel" error-channel="errorChannel"/> 使用此配置max-concurrent-consumers =“30”我们预计有30个并行消费者（processRequest-container-1到30）来消费消息，但在测试过程中我们发现每个消费者依次消费10条消息，Eg - processRequest-container-1 处理消息 1 到 10，然后创建 processRequest-container-2 并处理 11 到 20 等等.. 如果只有 2 个请求，这会导致第二条消息等待，即使还有 29 个其他消费者。分辨率我们添加了 max-messages-per-task="1"，这似乎产生了正确的结果，但我们仍在使用大量消息进行测试。 <jms:message-driven-channel-adapter id="processRequest" destination="requestFromLoader" connection-factory="connectionFactory" max-concurrent-consumers="30" max-messages-per-task="1" message-converter="xmlMarshalConverter" channel="jmsInChannel" error-channel="errorChannel"/> 问题我们通知日志中的消费者名称（processRequest-container-1）将达到2000或3000（processRequest-container-2546），并且不限于processRequest-container-1到processRequest-container-30，但在第一种情况下，没有 max-messages-per-task="1" 它没有超出 processRequest-container-30，这正常吗？或者我们需要做些什么吗？在spring文档中max-messages-per-task =“1”被定义为每条消息要执行的任务，什么是任务以及最大并行消费者如何受此影响？添加 max-messages-per-task="1" 正确还是我们遗漏/忽略了其他内容？任何建议或评论都很好。预先感谢。这个问题更多的是关于 Spring JMS，而不是 Spring Integration。最好阅读用于上述 DefaultMessageListenerContainer 的 <jms:message-driven-channel-adapter> 的源代码和 Javadoc。有一条有趣的评论可能可以解释您的行为： /** * Specify the maximum number of concurrent consumers to create. Default is 1. * If this setting is higher than "concurrentConsumers", the listener container * will dynamically schedule surplus consumers at runtime, provided that enough * incoming messages are encountered. Once the load goes down again, the number of * consumers will be reduced to the standard level ("concurrentConsumers") again. * Raising the number of concurrent consumers is recommendable in order * to scale the consumption of messages coming in from a queue. However, * note that any ordering guarantees are lost once multiple consumers are * registered. In general, stick with 1 consumer for low-volume queues. * Do not raise the number of concurrent consumers for a topic, * unless vendor-specific setup measures clearly allow for it. * With regular setup, this would lead to concurrent consumption * of the same message, which is hardly ever desirable. * This setting can be modified at runtime, for example through JMX. * @see #setConcurrentConsumers */ public void setMaxConcurrentConsumers(int maxConcurrentConsumers) { 因此，由于您不使用 concurrent-consumers="30" 来代替，因此您获得最多 30 个动态实例，并且它们的 id 确实增加了，这是正常的。如果不指定max-messages-per-task="1"，逻辑是这样的： if (this.taskExecutor instanceof SchedulingTaskExecutor ste && ste.prefersShortLivedTasks()) { if (this.maxMessagesPerTask == Integer.MIN_VALUE) { // TaskExecutor indicated a preference for short-lived tasks. According to // setMaxMessagesPerTask javadoc, we'll use 10 message per task in this case // unless the user specified a custom value. this.maxMessagesPerTask = 10; } } 或者你的taskExecutor不是那个SchedulingTaskExecutor（这确实是默认情况下），因此你的所有消息都由同一个消费者实例处理。一些文档也在这里：https://docs.spring.io/spring-framework/reference/integration/jms/using.html#jms-mdp

java spring concurrency spring-integration spring-jms

回答 1 投票 0

如何将 AdMob `GADFullScreenContentDelegate` 转换为 Swift 6 并发

这与如何将 `VNDocumentCameraViewControllerDelegate` 转换为 Swift 6 并发类似，但有一个警告是新的，因此可能需要不同的解决方案。我有以下代码： @

ios swift concurrency admob swift6

回答 1 投票 0

NextJS API 端点中的 NextJS 服务器操作使用情况 - 并发与否？

正如我通过实践了解到的：NextJS 服务器操作是同步的。我想实现并发；我喜欢将其抽象化的语法；因此我创建了一个 NextJS API 端点，它具有

next.js concurrency server-side nextjs14

回答 1 投票 0

具有并发任务（可以限制）的单实例WCF服务

我正在尝试构建一个 WCF 服务 - 是单实例允许客户端向函数发出多个请求（例如 StartJob） StarJob(request) 将请求“排队”到 TaskFactory（一分钟...