concurrency 相关问题

在计算机科学中，并发性是系统的属性，其中可以在重叠的时间段中执行多个计算。计算可以在同一芯片中的多个核上执行，在同一处理器上抢占时间共享线程，或者在物理上分离的处理器上执行。

假设我有以下代码：类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（一分钟...