腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
java
生产者
消费者
模式
结束信号
java
、
design-patterns
我有一个应用
生产者
-
消费者
设计
模式
的应用程序。它是用
java
编写的。简而言之,
生产者
将项目放在阻塞队列中,
消费者
从那里取出项目。
消费者
应该一直运行,直到
生产者
发出停止的信号。将这个信号从
生产者
传递给
消费者
的最好的方式是什么?首席设计师说他希望保持
生产者
和
消费者
的分离,但除了在
消费者
线程池上调用一个方法之外,我没有看到其他任何方法。
浏览 4
提问于2013-05-13
得票数 1
回答已采纳
2
回答
执行者框架-
生产者
消费
模式
java
、
multithreading
、
design-patterns
、
io
、
executorservice
许多
生产者
-
消费者
设计可以用Executor任务执行框架来表示,本身就是使用
生产者
-
消费者
模式
。如果是的话,
生产者
-
消费者
模式
对框架的实现有什么帮助?
浏览 1
提问于2017-10-24
得票数 1
回答已采纳
1
回答
使用
java
和spring的
生产者
-使用者
模式
java
、
spring
、
producer-consumer
我需要使用使用
Java
和Spring框架的
生产者
-
消费者
模式
来解决问题。问题是我是Spring框架中的新手(我不知道),所以有人能指导我如何使用Spring来实现这个目标吗?一些书或网站,我可以找到一个例子,一步一步地实施
生产者
-
消费者
模式
与Spring?
浏览 0
提问于2016-02-05
得票数 2
2
回答
如何在使用LinkedBlockingQueue时优先考虑
消费者
?
java
、
concurrency
我结合使用LinkedBlockingQueue和
生产者
/
消费者
模式
来缓冲任务。要将任务添加到队列,我使用
生产者
的方法: Queue.put(Object);要从队列中提取任务,我使用
消费者
: Queue.take(Object); 我在
Java
api中发现,这两种方法都会阻塞,我的问题是:我知道在我的系统中有更多的任务
生产者
,而不是
消费者
。我所有的任务都需要处理。因此,我需要我的
消费者
在被阻塞时拥有比
生产者</e
浏览 0
提问于2013-07-19
得票数 1
回答已采纳
1
回答
卡夫卡
消费者
从哪里获得第一个版本的Avro
模式
?
apache-kafka
、
avro
、
quarkus
说明Avro和服务注册中心使用情况的大多数Quarkus示例将
消费者
和
生产者
结合在同一个项目中。在这样做时,
模式
和生成的类对
生产者
和使用者都是可用的。我理解
模式
注册中心的作用是维护
模式
的各种版本,并将它们提供给
消费者
。 我不完全理解的是使用者如何以及何时从注册表中提取
模式
。例如,使用者的团队如何获得
模式
的初始版本?他们只是去注册表并手动下载吗?对于Quarkus,avro扩展将自动从avro
模式
生成
Java<
浏览 10
提问于2022-07-23
得票数 0
1
回答
在无栈python中,通过通道发送的数据是不可变的吗?
python
、
immutability
、
stackless
、
python-stackless
我有一个典型的
生产者
,
消费者
模式
。如果
生产者
通过通道发送对象,则
生产者
将被阻塞,直到
消费者
接受该对象。在
消费者
接受对象之后,
生产者
以某种方式改变对象。
消费者
看到对象被改变了吗?
浏览 4
提问于2010-10-29
得票数 2
回答已采纳
1
回答
如何拥有动态数量的
生产者
和
消费者
?
java
、
concurrency
、
producer-consumer
有一个程序是使用
生产者
和
消费者
模式
实现的。
生产者
根据查询列表从数据库中获取数据,并将其放入数组阻塞队列中...
消费者
根据数组阻塞队列中的数据编制excel报表。为了提高性能,我希望拥有动态数量的
生产者
和
消费者
。例如,当
生产者
速度慢时,拥有更多的
生产者
..当
消费者
慢的时候,有更多的
消费者
。我怎样才能拥有动态的
生产者
和
消费者
?
浏览 0
提问于2018-07-29
得票数 0
1
回答
我们是否需要做
消费者
驱动的合同测试卡夫卡驱动的微型服务,当我们有计划注册?
apache-kafka
、
confluent-platform
、
confluent-schema-registry
、
pact
、
spring-cloud-contract
我试图理解
消费者
驱动契约( )的概念在基于卡夫卡的事件驱动体系结构中是否仍然有效。 在RESTful世界中,
消费者
驱动的契约验证是至关重要的,因为在运行时没有基于
模式
进化的兼容性测试的概念。一个坏的
生产者
可以在不通知使用者的情况下自由地更改
模式
和部署,如果API没有正确地进行版本化,如果
生产者
没有注意到使用者
模式
,这可能会破坏您的使用者。因此,在我看来,CDC的概念提供了确保
生产者
在发展他们的
模式
时保持
消费者
依从性
浏览 5
提问于2022-02-08
得票数 0
1
回答
如何表示数据库中两个实体之间的权限控制?
database
我有以下实体:
生产者
,
消费者
。举个例子,我有
生产者
p1,p2,p3和
消费者
c1,c2,c3。c1 c2 c3p2 Y N N记住
消费者
和<em
浏览 0
提问于2018-02-09
得票数 0
1
回答
使用
模式
演化的Kafka avro序列化
apache-kafka
、
avro
、
kafka-producer-api
我在
模式
注册表中使用AVRO序列化,因为我的
模式
会定期更改。我很困惑在这两个选项之间做出选择。 由于我的
模式
经常更改,您能建议我哪一个更好吗?
浏览 1
提问于2018-05-15
得票数 0
1
回答
如何映射两个实体之间的权限控制?
database-design
、
schema
我有以下实体:
生产者
,
消费者
。举个例子,我有
生产者
p1,p2,p3和
消费者
c1,c2,c3。c1 c2 c3p2 Y N N记住
消费者
和
生
浏览 0
提问于2018-02-08
得票数 1
2
回答
如何在
Java
中实现一个
生产者
、多个
消费者
和多个对象?
java
、
design-patterns
、
producer-consumer
我有一个关于
生产者
/
消费者
设计
模式
的问题,实际上我的情况是:我有一个产生多种类型消息(通知)的类和多个消费这些消息的
消费者
。 复杂的是,我的
生产者
产生不同类型的消息,而我的
消费者
消费这些消息。
生产者
/
消费者
设计
模式
是这种情况的最佳解决方案吗?
浏览 0
提问于2010-06-26
得票数 0
4
回答
notify可以多次唤醒同一个线程吗?
java
、
multithreading
、
synchronization
、
notify
假设您在
Java
中有一个典型的
生产者
-
消费者
模式
。为了提高效率,当向队列中添加新元素时,您希望使用notify()而不是notifyAll()。如果两个
生产者
线程调用notify,是否保证两个不同的等待
消费者
线程将被唤醒?或者,会不会是两个紧接着触发的notify()导致同一个
消费者
线程排队等待唤醒两次?
java
是否有一些原子内部操作来唤醒线程一次? 如果只有一个
消费者
在等待,那么第二个通知将丢失,这是没有问题的。
浏览 3
提问于2012-05-21
得票数 11
回答已采纳
1
回答
在
生产者
/
消费者
模式
中使用多个
生产者
和
消费者
来对
java
中的字符串进行排序有什么好处?
java
、
multithreading
、
producer-consumer
我们在课堂上学习了
生产者
/
消费者
模式
,但仅以一个
生产者
和一个
消费者
为例。在我们的家庭作业中,我们被要求做以下工作: 在这种情况下,有人能向我解释实行多
生产者
和多
消费者
而不是单一
生产者
和
消费者
的好处吗?我假设
浏览 0
提问于2020-04-18
得票数 0
回答已采纳
2
回答
多个
生产者
和一个
消费者
的并发
java
、
multithreading
、
design-patterns
、
concurrency
我是
Java
并发性的新手。我听说过
生产者
/
消费者
模型,在这种
模式
下,一个
生产者
生产一些东西,一个
消费者
使用它。但在上面的场景中,我认为有两个
生产者
-奇数生成器和偶数生成器和一个
消费者
。如果我用
生产者
-
消费者
模型来解决这个问题,那么我说的对吗?或者有没有其他技术可以解决这个问题?有没有人能提供一个很好的例子/资源链接?谢谢。
浏览 1
提问于2014-04-28
得票数 0
1
回答
Java
:具有长生命周期
消费者
和短生命周期
生产者
的处理保证的并发队列
java
、
concurrency
、
producer-consumer
我正在寻找并发队列的现有实现,该实现可用于实现典型的
生产者
-
消费者
模式
,但需要注意以下几点。每个
生产者
都是短暂的,但在退出之前必须阻塞,直到它放在队列上的所有消息都被
消费者
处理完。
消费者
和队列是长期存在的。 我的一些想法是,要么使用单个分区队列,其中每个分区被分配给一个
生产者
,要么为每个
生产者
建立一个专用队列,并在
生产者
队列之上构建一种复合队列,供
消费者
使用。这似乎是http服务器的常见
模式
,它有许
浏览 37
提问于2018-10-14
得票数 4
1
回答
针对一个观察者的多学科的正确设计
模式
java
、
oop
、
design-patterns
、
observer-pattern
在观察者
模式
中,主体和观察者之间通常存在一对多的关系(有一个主体和多个观察者)。我可以使用什么样的设计
模式
/范例呢?
浏览 4
提问于2016-04-12
得票数 0
回答已采纳
1
回答
在Apache中使用已注册
模式
发布到主题
apache-pulsar
、
python-pulsar
User.class)) .create();producer.send(User);现在,是否有可能从Python
生产者
那里发送一条关于Pulsar主题的消息,该主题将由具有注册
模式
的
消费者
使用?
浏览 3
提问于2019-10-23
得票数 2
回答已采纳
1
回答
我需要一个具有.NET 4.0新特性的单一
生产者
/单一
消费者
模式
的样本
c#
、
multithreading
、
.net-4.0
、
producer-consumer
对于使用这些特性的单一
生产者
-单一
消费者
模式
,有没有什么好的例子?(实际上,如果它还没有将其实现为共享缓冲区,我将添加一个循环缓冲区
模式
)
浏览 0
提问于2010-10-26
得票数 3
回答已采纳
4
回答
对于同时运行的两个线程,多长睡眠时间是好的
java
、
multithreading
、
performance
我旋转了两个线程,一个从文件中读取(混合
模式
的流和使用Gson逐个读取对象),将对象放入阻塞队列,第二个线程从队列中读取数据,并使用1000的批处理大小保存到数据库中。
浏览 1
提问于2018-10-03
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
生产者-消费者模型:Java与Go实现对比
如何用Java编写代码解决生产者消费者问题?
4.kafka生产者&消费者
【Kafka】生产者客户端小结(java)
Python的Socket知识7:队列、生产者消费者模型
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券