1回答
JMS中的多线程
、、、、
我需要编写一个多线程JMS生产者和一个多线程JMS消费者；我对使用JMS比较陌生，以前从未使用过多线程。我在API中看到，您可以使用生产者的完成侦听器和消费者的消息侦听器异步发送和接收消息。这是否意味着使用完成侦听器和消息侦听器会导致程序多线程？如果没有，那么如何编写多线程生产者和多线程消费者呢？
浏览 1提问于2015-06-08得票数 1
我已经使用kafka_2.9.2-0.8.1.1创建了示例kafka同步生产者和消费者组程序。所以我的问题是，我是否需要向生产者添加多线程代码(就像consumergroup类一样)来支持大量的请求？我读到生产者发送方法是线程安全的。那么kafka producer将在内部处理多线程概念，还是开发人员必须显式编码？谢谢，Cdhar
浏览 2提问于2015-02-16得票数 2
2回答
我之所以要求这样做，是因为我有很多线程，比如10，充当使用者，和2个生产者，每个使用者线程都有自己的链接列表(缓冲器)，生产者会根据特定的规则将数据发送到这些线程中的一个，所以有时候生产者1发送给消费者所以我在想这个，
生产者1调用函数链接-列表来共享数据(IPC)并将lock5传递给这个函数，在这种情况下，它将是锁5。当使用者5调用函数链接列表时，它将传递它的锁(consumer5总是使用lock5)，如果生产者已经锁定了这个锁，那么
浏览 1提问于2012-12-25得票数 0
我想在项目中使用Kafka的消费者和生产者的事务功能。我需要尽可能高效地在Kafka中产生大量的消息。所以我需要一个多线程的消费和生产来满足这个需求。如何使用Spring boot开发多线程消费者和生产者？
浏览 81提问于2020-10-14得票数 0
回答已采纳
我正在学习Linux进程调度程序，并一直在阅读pthread_setsched函数：https://man7.org/linux/man-pages/man3/pthread_setschedparam我可以看到，这对于配置某些多线程应用程序(例如生产者和使用者)是有意义的，但是，任何进程都可以请求设置自己的优先级，这似乎是一个系统稳定性风险。
浏览 0提问于2022-02-16得票数 -1
回答已采纳
1回答
或者仅仅是对用法的误解？
、、、、
我正在维护一个用C++编写的多线程的linux服务器应用程序。这里大约有10个模块和数十个std::deques用于消息传递。该应用程序使用生产者-消费者模式在模块之间传递网络数据包。生产者-消费者设计模式在许多情况下都表现良好，但我不认为它适合我们的应用程序。CSomeMod::OutqueWorkThread --> //Optional Linux
浏览 0提问于2013-06-02得票数 0
回答已采纳
1回答
我想用生产者/消费者模式来使用多线程。我没有多线程编程的经验，所以我在网上搜索了一些教程。我发现的所有教程都是关于一个生产者和一个消费者的，但我需要的是稍微不同的:我的需求是一个生产者，它向两个消费者发送相同的图像，在两个消费者完成他们的工作之后，继续下一个框架。关键是生产者将有一个队列来存储框架，而使用者都需要从同一个队列读取同一元素一次。
你有什么
浏览 4提问于2015-11-13得票数 0
回答已采纳
6回答
我正在看一个关于Java多线程的视频教程。介绍了用Java实现著名的“生产者-消费者”问题。
它使用wait()和notifyAll()来确保生产者线程和消费者线程之间的正确通信。这位导师故意创建了几个生产者线程，而只有一个消费者线程，但他留下了一个未回答的问题：“最好是生产者线程和消费者线程的数量相等，如果生产者线程比消费者线程多，就会有问题”。
浏览 2提问于2013-04-05得票数 5
回答已采纳
3回答
一个进程将充当“生产者”，另一个进程将充当“消费者”。在多线程系统中，我的方法是使用互斥和condvar (条件变量)对，当共享内存更新时，使用者等待condvar (使用pthread_cond_wait)，生产者发送信号(使用pthread_cond_signal如何在多进程而不是多线程架构中实现这一点？或者在这种情况下是否有其他的同步机制更合适？
浏览 3提问于2010-04-06得票数 14
回答已采纳
1回答
我编写了一个测试多线程生产者/消费者模型的小案例。我的测试平台是一台低性能的PC(8GRAM，J1900 4核)。我为Linux内核隔离了核心0，内核1-3是未使用的。生产者线程运行在核心1上，分配5000000个小对象，并将它们放到全局队列中。使用者线程在核心2上运行，并从队列中释放对象。如果我的前提是不正确的(“设置CPU亲和力可以提高多线程进程的性能”)，那么它至少不会变得更糟。
浏览 0提问于2016-09-14得票数 4
回答已采纳
2回答
我正在尝试用BlockingQueue构建一个通用的生产者/消费者。
我希望它是尽可能多的多线程或并行，但不要吃掉所有的计算机资源。假设我们有一个生产者，那么在使用数据时，让使用者作为线程还是有任务的使用者更好？
浏览 3提问于2011-04-26得票数 0
回答已采纳
1回答
我遇到了一个消费者/生产者问题，我有一个简单的服务器，它的端点从队列中消耗，一个函数生成到队列上。队列可以是满的，所以生产者并不总是需要运行。当队列没有满时，我希望生产者任务运行，但我不希望它阻止服务器接收或服务请求。我试过使用多线程，但是这个生产过程非常慢，而且GIL太慢了。我希望服务器一直在运行，每当队列不再满时(某些内容已被消耗)，我希望启动这个生产者任务，作为一个单独的进程，并希望它运行，直到队列再次满。共享队列的最佳方式是什么，以便生产者进程能够访问主进程使用的队列？
浏览 2提问于2018-09-18得票数 0
回答已采纳
1回答
在Apple的并发编程指南中从线程迁移一节中，有
// Process a work item.
浏览 4提问于2011-10-17得票数 16
回答已采纳
让我们考虑一下多线程的跨国kafka生产者。我应该在关闭前使用flush() producer吗？换句话说，Transactional是否在发送数据之前对数据进行批量缓冲？
浏览 0提问于2020-02-20得票数 1
method=processOrders").id("asyncProcessChannelToId");}所以我认为总会有一个线程的生产者。
浏览 0提问于2018-11-18得票数 0
回答已采纳
1回答
我正在尝试使用Java多线程从生产者那里读取卡夫卡消息。
假设卡夫卡制片人向Kafka Consumer发送多条消息。然后，如何使用JAVA ExecutorService中的分别读取这些多条消息
浏览 1提问于2018-05-18得票数 2
1回答
我需要在lxc容器中运行spacy，这样我就可以使用python3.6运行它(它允许在训练时使用多线程)。- spaCy版本2.0.8Linux-3.14.32-xxxx-grs-ipv6-64-x86
浏览 2提问于2018-03-26得票数 2
回答已采纳
我编写了一个代码，用于查看Java中的生产者-消费者关系，如下所示。虽然程序运行良好，但我看到输出中有不一致之处。有谁能说明以下不一致的原因吗？
浏览 0提问于2013-11-11得票数 1
回答已采纳
我试图用多个生产者和一个使用者实现并发生产者/消费者队列:生产者向Queue添加一些数据，使用者从队列中删除这些数据以更新集合。必须定期将此集合备份到新文件。队列只在使用者和生产者之间共享，因此必须管理对此队列的访问，以避免竞争条件。
自定义集合在使用者和备份线程之间共享。最后，关闭方法应该停止生产者的排队，然后停止使用者，执行最后的备份并释放计时器。一次一项的脱队列可能并不有效，所以我想使用两个队列:当第一个队列满时，生产者通过调用Monitor.Pulse通知使用者。一
浏览 2提问于2012-09-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
