回答情况：
提问时间：
问题标签：
我发现github中的Lmax Disruptor的用户指南非常简单，现在我有一个生产者和五个消费者的问题，之后我需要总结消费者的结果，有任何演示，如何找到Lmax Disruptor钻石(一个生产者5
浏览 14提问于2015-02-03得票数 1
2回答
可能重复：
在c#中实现这一点的最佳解决方案是什么。目前，我已经实现了使用信号量，但生产者似乎建立了一个缓冲区100多个项目非常迅速。我没有语法来处理，将缓冲区限制为5项。我正在考虑使用一个静态整数-让生产者增加它-当它达到5，生产者去睡觉。让消费者减少它并唤醒生产者。
浏览 0修改于2017-05-23得票数 0
我之所以要求这样做，是因为我有很多线程，比如10，充当使用者，和2个生产者，每个使用者线程都有自己的链接列表(缓冲器)，生产者会根据特定的规则将数据发送到这些线程中的一个，所以有时候生产者1发送给消费者所以我在想这个，
当使用者5调用
浏览 1修改于2015-09-16得票数 0
我正在研究Java的生产者-消费者问题的多个生产者和消费者用例。代码在上。同样的实现也适用于用例，但对于多个生产者消费者用例却表现得很奇怪。关于产出，我有几个问题：Producer t1 has lockProducer t5当生产者线程t5持有锁时，使用者线程t1是如何获得锁的？Producer t5 has loc
浏览 1修改于2019-09-24得票数 0
回答已采纳
我正在编写一个具有多生产者、单消费者模型的应用程序(多线程将消息发送到单个文件写入器线程)。在消费者线程的循环中，它在处理完所有生产者线程后休眠一段指定的时间。我立即注意到的一件事是，当我从1个生产者线程转移到2个生产者线程时，生产者将一些东西写入队列并
浏览 4提问于2009-09-09得票数 2
回答已采纳
我们有两层代码，第一层是消费者，另一层是生产者。2)。消费者正在调用生产者，因为生产者有许多微服务。3)。在调用过程中，Producer正在生成唯一的ID以用于事务跟踪。4)。我们可以直接调用生产者，它将生成结果集。5)。在生产者调用期间，我们必须在来自POSTMAN的标题中添加唯一的日志事务ID。现在的问题是，如果想要直接命中生产者，并且不想传递日志事务ID，有没有办法让我的生产者路由器理解头部中没有LOGTRANSACTION，它将生成一个名为&q
浏览 21提问于2019-06-12得票数 0
让卡夫卡生产者使用acks=all配置，有5个代理副本具有min.insync.replica=2配置。据我所知，如果三个经纪人离线，但两个经纪人仍然是健全的，那么生产者仍将得到消息确认，并将能够继续发送消息。
但是，如果所有5位经纪人都健康健康，会发生什么呢？#1，生产者会只在所有5个代理都写完消息后才收到确认吗？#2，还是生产者在2个代理写完消息后就已经收到了确认？因此，它不会等待其他3个经纪人的反馈？？。在所有代理副本都健康的情况下，我对吞吐量很感兴趣：min.i
浏览 2修改于2022-11-26得票数 1
回答已采纳
我正在编写一个示例程序，它有一个生产者线程和两个消费者线程。4)解锁互斥pthread_mutex_lock(&cons1Mux)在消费者
1)锁定互斥pthread_mutex_lock(&cons1Mux)5)解锁互斥锁pthread_mut
浏览 4修改于2010-06-26得票数 2
回答已采纳
但是当我们调用API时，我们的生产者会为我们的值获取一些特殊的字符。queryParameters.add("ABC")；finalMap.put("column"，列
浏览 1提问于2021-02-19得票数 0
我想实现生产者-消费者场景，其中有一个生产者线程和多个消费者线程。实际上，生产者线程需要以固定的时间间隔(例如，5秒)创建一组对象，而消费者线程需要使用这些对象。
浏览 1修改于2012-08-31得票数 0
卡夫卡文献
当生产者将ack设置为"all“(或"-1")时，此min.insync.replica配置指定必须确认写入才能被认为成功的副本的最小数量。它说，当最小数量的同步副本确认时，写入是成功的，但是当我使用min.insync.replica作为1和3运行性能测试时(对于5 broker设置中的partition=1和R.F=5主题)，卡夫卡生产者的性能与那么，min.insync.replica每个主题的配置是否会影响acks="all"的卡夫卡生产者</
浏览 0修改于2018-09-07得票数 5
回答已采纳
从生产者的角度，我只需要向5个消费者发送一条消息。假设有5个消费者具有唯一的id 1,2,3,4,5，我在生产者端使用字符串连接"1,2,3,4,5“包括了这一点，我在从生产者的角度，我们让消费者的id发送出去
浏览 0修改于2020-08-22得票数 1
1回答
当生产者被设置为customPartition时，无法从生产者发送消息到脉冲星(请参考下面的代码)。MessageRounterImpl())发送消息的代码：MessageRouterImpl随机生成从0到5的数字> msg, TopicMetadata metadata) { return r.nextInt((0 - 5) + 1);}}
我的
浏览 1修改于2020-06-20得票数 1
我写了一个关于如何使用omp flush在线程之间以生产者->消费者的方式交换数据的非常简单的例子，我发现了一个有趣的行为。a: 1标志:1 TID 0生产者a: 2标志:1 TID 0生产者a: 3标志:1 TID 0生产者a: 4标志:1 TID 0生产者a: 5标志:1 TID 0
消费者a:
浏览 2修改于2011-02-26得票数 3
回答已采纳
生产者函数每5秒创建一个新对象，而使用者函数可能在5秒内消耗一个对象更长的时间。使用者函数具有处理3个对象的能力。消费者是否有办法让生产者知道生产者需要等到消费者有额外的生产能力？Populate-NextIcon -List $list| foreach-object { $_ | Launch-Icon }
function
浏览 1提问于2021-02-08得票数 1
回答已采纳
我有一个问题，关于发送电话和生产者的‘杰克’财产。我观察到下面的数字，下面调用发送呼叫。这是一个简单的火灾和忘记电话。producer.send(record); // fire and forget call
主题有5个分区，我看到下面的结果有不同的ack值和复制因子。kafka集群有5个节点运行默认值并使用本地磁盘。我所不能理解的是，如果生产者发出的电话是火而忘记了性质(见上文)，生产者没有等待任何确认，那么，为什么生产者的吞吐量下降，因为我们转向更强大的保障？任
浏览 0修改于2018-11-19得票数 2
回答已采纳
我有一个带有生产者和产品表的数据库，我正在试图找到平均价格最高的产品的生产者。基本上，我要找出每个生产者的平均水平，然后找出平均价格最高的生产者，如果他们有相同的平均水平，就可以有多个生产者拥有最昂贵的平均水平。例子: producerID \x{e 010}平均值2 | 8.54 | 9
5
浏览 5修改于2015-04-12得票数 0
回答已采纳
背景：1)消费者上传要生产的对象2)我们提供合格生产者的列表3)消费者从列表中选择生产者4)消费者支付5)生产者通知工作，可以接受/拒绝工作6a)如果接受-生产者创建产品并交付给消费者6b)如果拒绝如果Paypal没有这个功能，我们很可能会有一个自动化的电子邮件系统，这将需要生产者接受/拒绝，在其中我们将不得不手动发出退款。
浏览 0提问于2013-04-13得票数 1
直到最近，我还认为生产者、领导人选举和元数据的过程是这样的：
这将触发生产者与代理联系，以获取一个新的元数据块，这样它就可以找到新的领导者并继续。然而，我观察到的是，生产者在耗尽重试之后阻塞，在元数据“自动”刷新之前什么也不做。因此，基本上，如果生产者碰巧在元数据过期的时间附近阻塞，那么生产就会迅速恢复。但是，如果生产者
浏览 1提问于2016-09-02得票数 2
我正在使用spring-kafka 2.2.8，并使用以下设置编写了一个简单的生成器: linger.ms :5 max.block.ms: 60000 现在我的问题是，如果生产者应用程序在发送到代理之前崩溃，生产者'buffer.memory‘中的消息会发生什么情况(特别是在异步生产者调用模式下)？
浏览 6提问于2020-07-08得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号