我正在使用ExecutorService和BlockingQueue解决使用生产者-消费者问题的事务轮询案例。我有一个交易列表，我想要验证这些交易并采取行动。我正在获得一个新的交易，以不断验证。考虑到BlockingQueue，我只有一个生产者，我想保持3-5个并行消费者来加速验证。
我可能需要等待一些事务才能完成。(比如30秒)。，我可
浏览 13提问于2019-08-16得票数 1
1回答
在.net中，对于少数生产者(线程)和一个消费者来说，什么是最有效的同步集合？生产比消费快得多。排序是必需的。
它只是ConcurrentQueue上的默认BlockingCollection吗
浏览 0提问于2013-12-27得票数 0
1回答
有人知道directshow过滤器是如何交换媒体示例的吗？显然，我想知道过滤器是如何将样本传递给另一个过滤器的？有什么已知的模式吗？说源滤波器
浏览 2提问于2014-07-20得票数 0
回答已采纳
2回答
一次使用多条消息
、、
我正在使用外部服务( service )来处理某些特定类型的对象。如果我以10的批处理发送对象，则服务工作得更快。生产者一个接一个地广播对象，一群消费者把它们(一个接一个地)从队列中拉出来，并将它们发送到服务。这显然不是最优的。
我不想修改生产者代码，因为它可以在不同的情况下使用。我可以修改使用者代码，但只需要
浏览 7提问于2014-05-29得票数 9
1回答
我的任务是提高进行rpc调用的效率。我相信我可以使用生产者和消费者的例子。生产者将得到响应，而消费者将把接收到的对象写入文件。 5 is_ex
浏览 0提问于2013-02-22得票数 0
回答已采纳
我刚刚开始使用Spring boot RabbitMQ。我想知道在spring boot rabbitmq (注解配置)的情况下，我们如何分别配置生产者代码和消费者代码。我的意思是，如果我想在spring boot中编写rabbitmq生产者代码，用python编写消费者代码，或者反之亦然-在spring boot中编写消费者代码，在</
浏览 2提问于2018-03-25得票数 0
我们在课堂上学习了生产者/消费者模式，但仅以一个生产者和一个消费者为例。在我们的家庭作业中，我们被要求做以下工作：
在这种情况下，有人能向我解释实行多<em
浏览 0提问于2020-04-18得票数 0
回答已采纳
是否可以在消费者端存储合同定义？
在文档和示例存储库(spring-cloud- contract - samples )中，只有合同存储在公共存储库或生产者端的示例和描述。据我所知，这支持这样一种架构，即一个生产者发布消息，一个或多个消费者消费它们。在这种情况下，将契约存储在生产者端实际上是有意义的。但是我有一个系统，其中许多生产者将消息发布到
浏览 0提问于2017-05-22得票数 1
我正在寻找建立一个几十台机器的分布式视频编码集群。我以前从未使用过消息队列，但我开始使用的两个队列是Gearman和Beanstalkd。Beanstalk似乎比Gearman更简单，更容易使用，但它的功能并不像Gearman那样丰富。
我不明白的一件事是。如何在所有服务器上生成新的工作进程？我计划使用php。我注意到gearman实际上不会在作业完成后终止进程，但Beanstalk会，所以我必须在每个作业后
浏览 1提问于2012-02-23得票数 7
1回答
我是Spring契约的新手，最近我能够生成生产者合同，并使用安装在本地maven回购上的存根在消费者端编写测试。如果我在生产者端违反合同，然后安装新存根，正如我运行使用者测试时所预期的那样，它将失败。但是想象一下这样的场景：
Producer被改变了，在consumer-aTests上的生产者 pass上违反了合同，所以build成功了，最终<e
浏览 9提问于2022-04-12得票数 0
回答已采纳
场景1:生产者->队列->消费者生产者-> Queue1 ->骆驼(再排序) ->Queue2 ->消费者我们可以在不使用骆驼Queue2的情况下完成场景2吗？我希望消费者在<
浏览 2提问于2019-05-22得票数 0
从类库中，我计划提供一些选项，以便可以在客户端上累积记录的消息，并以“突发”的形式发送到WCF日志记录服务，而不是在发生时发送每条消息。一般来说，这是很好的工作。然而，我的消息似乎也在如此迅速地连续发生，以至于异步调用中留下的消息的“突发”实际上是以与生成的顺序不同的方式“离开”客户机。我试图设置一个生产者<e
浏览 1提问于2010-11-09得票数 1
回答已采纳
5回答
生产者-消费者使用赋值
、、、
我感兴趣的是，当有多个生产者和多个消费者时，生产者-消费者问题是否可以在不使用赋值的情况下解决，即使用函数式编程风格？多么?
谢谢
浏览 0提问于2009-08-05得票数 3
回答已采纳
1回答
我对web服务很陌生，只是碰到了生产者(服务器)和消费者(客户端)的概念。由于我可以从其他来源搜索，生产者被定义为生成数据的应用程序，而消费者是消费这些数据的应用程序。这是可以理解的，当您以在线订购服务为生产者，并将订购数据发送到后端运输服务，在这种情况下，它是消费者。但当用户在移动应用程序上查询帐户报表时，当后端数据库将数据返
浏览 0提问于2022-08-07得票数 0
1回答
;}在某些情况下，我希望能够让生产者在调用上面的生产者代码之前等待，直到所有消费者都在Monitor.Wait()调用中。让我们将问题简化为单个消费者的<
浏览 24提问于2019-11-07得票数 2
我正在努力实施一个生产者-消费者pgm。共享资源是队列(对象数组-大小为5)。生产者添加一个对象并通知使用者，当Q为满时，waits.Consumer在Q为空时等待，否则将读取/移除并通知生产者它已完成。我无法理解的是
有谁能帮我克服这个问题吗？我知
浏览 6提问于2013-09-12得票数 0
2回答
因此我有多个步骤阶段1 ->阶段2 ->阶段3 -> stage4，所以在某些情况下生产者将是消费者，并且在每个阶段有多个生产者/消费者来利用多个cpus。在相关情况下，一些分组将遗漏步骤，即直接从阶段1到阶段4。因此，我打算为每个阶段创建一个类，与上一阶段共享一个BlockingQueue，但我也了解到，ExecutorService的工作方式类似于<
浏览 0提问于2011-11-09得票数 5
回答已采纳
我创建了一个场景，在这个场景中，一个具有生产者角色的客户端在kafka集群中发布一个主题中的消息，而一个具有消费者角色的客户端在这个主题中订阅并从日志中轮询消息。我的问题是，在此之后，具有消费者角色的客户端是否也成为一个进程(例如数据库处理)，并希望将一些数据发回，那么它必须将生产者角色和另一个客户端从他以前的生产者角色变成
浏览 0提问于2016-06-17得票数 3
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
