1回答
JMS中的多线程
、、、、
我需要编写一个多线程JMS生产者和一个多线程JMS消费者；我对使用JMS比较陌生，以前从未使用过多线程。我在API中看到，您可以使用生产者的完成侦听器和消费者的消息侦听器异步发送和接收消息。这是否意味着使用完成侦听器和消息侦听器会导致程序多线程？如果没有，那么如何编写多线程生产者和多线程消费者呢？
浏览 1提问于2015-06-08得票数 1
2回答
我之所以要求这样做，是因为我有很多线程，比如10，充当使用者，和2个生产者，每个使用者线程都有自己的链接列表(缓冲器)，生产者会根据特定的规则将数据发送到这些线程中的一个，所以有时候生产者1发送给消费者1，然后再发送给消费者2，然后返回到消费者1等等。所以我在想这个，
生产者1调用函数链接-列表来共享数据(IPC)并将lock5传递给这个函数，在这种情况下，它将是锁5。当使用者5调用
浏览 1提问于2012-12-25得票数 0
我想在项目中使用Kafka的消费者和生产者的事务功能。我需要尽可能高效地在Kafka中产生大量的消息。所以我需要一个多线程的消费和生产来满足这个需求。如何使用Spring boot开发多线程消费者和生产者？
浏览 81提问于2020-10-14得票数 0
回答已采纳
6回答
我正在看一个关于Java多线程的视频教程。介绍了用Java实现著名的“生产者-消费者”问题。
它使用wait()和notifyAll()来确保生产者线程和消费者线程之间的正确通信。这位导师故意创建了几个生产者线程，而只有一个消费者线程，但他留下了一个未回答的问题：“最好是生产者线程和消费者线程的数量相等，如果生产者线程比消费者线程多，就会有问题”。
浏览 2提问于2013-04-05得票数 5
回答已采纳
1回答
我想用生产者/消费者模式来使用多线程。我没有多线程编程的经验，所以我在网上搜索了一些教程。我发现的所有教程都是关于一个生产者和一个消费者的，但我需要的是稍微不同的:我的需求是一个生产者，它向两个消费者发送相同的图像，在两个消费者完成他们的工作之后，继续下一个框架。关键是生产
浏览 4提问于2015-11-13得票数 0
回答已采纳
我编写了一个代码，用于查看Java中的生产者-消费者关系，如下所示。虽然程序运行良好，但我看到输出中有不一致之处。有谁能说明以下不一致的原因吗？
浏览 0提问于2013-11-11得票数 1
回答已采纳
我已经使用kafka_2.9.2-0.8.1.1创建了示例kafka同步生产者和消费者组程序。所以我的问题是，我是否需要向生产者添加多线程代码(就像consumergroup类一样)来支持大量的请求？我读到生产者发送方法是线程安全的。那么kafka producer将在内部处理多线程概念，还是开发人员必须显式编码？谢谢，Cdhar
浏览 2提问于2015-02-16得票数 2
1回答
在Apple的并发编程指南中从线程迁移一节中，有
// Process a work item.
当您的生产者有工作要做时，它所要做的就是将该工作添加到队列中生产者-消费者问题也被称为边界缓冲问题，但上面没有提到缓冲区，它的约束或消费者，更不用说阻止生产者和<e
浏览 4提问于2011-10-17得票数 16
回答已采纳
1回答
对于我在消费者方面所理解的：
我发现很难从文档中指出这些问题，我想知道我是否错了。
这些考虑是双重的，甚至在生产者方面？
浏览 4提问于2016-11-04得票数 1
回答已采纳
1回答
或者仅仅是对用法的误解？
、、、、
我正在维护一个用C++编写的多线程的linux服务器应用程序。这里大约有10个模块和数十个std::deques用于消息传递。该应用程序使用生产者-消费者模式在模块之间传递网络数据包。生产者-消费者设计模式在许多情况下都表现良好，但我不认为它适合我们的应用程序。CSomeMod::OutqueWorkThread --> //Optional
CSockMod::Outque --> CSockMod::SendPackWorkerThread --
浏览 0提问于2013-06-02得票数 0
回答已采纳
我试图用多个生产者和一个使用者实现并发生产者/消费者队列:生产者向Queue添加一些数据，使用者从队列中删除这些数据以更新集合。必须定期将此集合备份到新文件。队列只在使用者和生产者之间共享，因此必须管理对此队列的访问，以避免竞争条件。
自定义集合在使用者和备份线程之间共享。最后，关闭方法应该停止生产者的排队，然后停止使用者，执行最后的备份并释放计时器。一次一项的脱队列可能并不有效，所以我想使用两个队列:当第一个队列满时，生产者通过调用Monitor.Pul
浏览 2提问于2012-09-13得票数 0
2回答
我正在编写一个BlockingQueue，我想知道其他实现如何解决这个问题：BlockingQueue%s是否使用两个显示器？一个是生产者在等待，另一个是消费者在等待？
浏览 2提问于2011-10-29得票数 2
回答已采纳
在访问多线程建模问题时，有两个模型经常被问到：
我的问题是，我无法理解这两种模式之间的本质区别。我对这两种模型的理解如下:对于生产者/消费者模型，生产者直到某些终止标准，在此条件下，生产者向消费者发出信号，等待另一个条件变量，而消费者则等到产品生产完毕，然后继续“消费”，通知生产者另一个插槽已准备好生产对我来说，它们都使用“互斥和条件变
浏览 1提问于2017-05-22得票数 0
1回答
用于多线程的Scala迭代器
、、、、
Try(anObject.foo()) }}
在并发和多线程中使用并且有多个生产者和消费者排队。因此，上面的代码块是这样的生产者或消费者的代码。anObject.foo是一种常见的简化函数声明，用于队列(生产者)或脱队列(用于使用者)数据到队列或从队列中删除。
浏览 0提问于2020-05-15得票数 1
在我们的Linux系统上，我们使用命名管道进行进程间通信(生产者和消费者)。
为了测试消费者(Java)代码，我想(用Java)实现一个虚拟生产者，它向连接到消费者的命名管道写入数据。在Linux中我可以使用mkfifo (称为使用Runtime.exec() )，但在Windows上该如何操作呢？
浏览 2提问于2009-03-11得票数 28
回答已采纳
我想要一个多生产者-单一消费者模式，生产者等待直到消费者完成。因为这是一个多线程环境，我需要使用者一个一个地处理项目。我希望避免手动放置锁(因为可能存在缺陷)，并使用类似奇妙的.Take()方法来阻止消费者，直到产生更多的项目为止，但我也需要相反的方法：
消费者应该等待产品，生产者应该等待消费者完成。因此，我有所有的服务请求，将项目发送给一个消费者。但是，在项
浏览 0提问于2018-06-06得票数 1
1回答
我试图模拟Python3多处理中的生产者-消费者设计。主要问题是生产者启动，但消费者直到生产者完成(在这种情况下，消费者没有启动，因为生产者永远不会结束)。#!我使用多线程来测试它，它可以工作，所以我想我对多重处理有一些误解。
谢谢。
浏览 6提问于2017-10-20得票数 1
回答已采纳
2回答
我使用的是一个多线程的生产者/消费者队列，它只有一个(非常快的)生产者和许多慢得多的消费者。每个消费者都可以独占访问一块物理硬件，例如电话线。生产者在主线程上运行，每个使用者在自己的线程上运行。我尝试做的是总是使用第一个消费者，如果它是可用的，如果它是繁忙的，那么使用第二个消费者。如果前两个很忙，那么使用第三个，以此类推。如果消费者2忙碌，消费者1现在准备好了，那么它应该使用第一个。简单地
浏览 1提问于2010-07-05得票数 1
回答已采纳
1回答
您知道我们可以将消息队列与函数mq_receive()一起使用；使用信号量实现该功能(您知道，等待共享数据被更改)的好方法是什么？
浏览 0提问于2010-04-03得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
