腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
使用
BlockingQueue
解决
容量
为
1
的
产品
消费者
问题
?
java
、
multithreading
、
concurrency
、
blockingqueue
我必须
使用
BlockingQueue
解决
生产-
消费者
问题
。我希望它是
1
个元素队列。因此
解决
方案必须是: 生产%
1
消耗%
1
生产%2消耗%2生产%3消耗%3 但它确实是: 生产
1
生产2消费
1
消费2生产3生产4等等。我目前
使用
的
SynchronizedQueue是这样
的
: class Producent extends Thread { private
浏览 15
提问于2021-05-08
得票数 1
回答已采纳
3
回答
如何
实现具有多个
消费者
和多个队列
的
消费者
生产者
java
、
concurrency
、
messaging
、
producer-consumer
、
java.util.concurrent
假设有
1
个生产者P和2个
消费者
C
1
和C2。并且有2个队列Q
1
和Q2,它们都具有特定
的
容量
。 P将生成项目,并将其交替放入Q
1
和Q2中。商品是
为
特定
消费者
生产
的
,不能被其他
消费者
消费。
如何
在java语言中实现以下功能:在启动3个线程后,如果Q
1
为
空,线程C
1
将被阻塞,直到Q
1
中出现异常时才会通知它。Q2也是如此。
浏览 3
提问于2013-05-31
得票数 8
2
回答
可调整
的
Java
BlockingQueue
java
、
concurrency
、
blockingqueue
因此,我在生产者/
消费者
类型
的
应用程序中
使用
固定大小
的
BlockingQueue
ArrayBlockingQueue,但我希望用户能够动态更改队列大小。
问题
是没有允许在创建后更改
容量
的
BlockingQueue
实现。以前有没有人遇到过这个?有什么想法吗?
浏览 0
提问于2011-07-07
得票数 10
2
回答
如何
从队列(ArrayBlockingQueue)中获得多个项?
java
、
arrays
、
multithreading
、
producer-consumer
解决
了生产者和
消费者
的
问题
。然而,它被扩展到包括一个仓库管理员。仓库管理员-将
产品
从第一个队列中取出,并将其重新粘贴到第二个队列中。
浏览 4
提问于2021-05-05
得票数 0
2
回答
生产者/
消费者
:一个生产者,多个
消费者
,每个人在同一数据上工作
java
、
multithreading
、
producer-consumer
我有一个生产者/
消费者
场景,我不希望一个生产者交付
产品
,多个
消费者
消费这些
产品
。然而,常见
的
情况是,交付
的
产品
只由一个
消费者
消费,而其他
消费者
从未看到过这个特定
的
产品
。我
的
第一个想法是
使用
多个BlockingQueues,每个
消费者
一个,并让生产者将每个
产品
依次放入所有可用
的
BlockingQueue
浏览 2
提问于2014-05-24
得票数 3
回答已采纳
1
回答
容量
为
1
的
数组阻塞队列错误行为生产者
消费者
java
、
multithreading
、
concurrency
、
producer-consumer
、
blockingqueue
我用
容量
为
1
的
阻塞队列做了下面的生产者
消费者
问题
。这样生产者只能产生一个项目,但运行代码生产者可以产生2个项目,
消费者
可以消费,即使队列是空
的
。import java.util.concurrent.ArrayBlockingQueue; clas
浏览 0
提问于2016-08-30
得票数 0
1
回答
BlockingQueue
资源消耗
java
、
multithreading
、
threadpool
我刚刚开始了解
如何
使用
BlockingQueue
(数组或链接),我想知道队列
如何
影响资源(CPU、内存等)? 从多大
的
角度来看,一个完整
的
队列开始成为服务器
的
问题
(不是线程
的
数量,而是比例)?
浏览 1
提问于2017-03-09
得票数 1
回答已采纳
3
回答
Java“分层队列”实现为快速生产者,慢
消费者
java
、
multithreading
、
concurrency
、
queue
、
threadpool
我有一个生产者-
消费者
的
场景,生产者生产
的
速度远远超过
消费者
的
消费能力。通常,
解决
方案是让producers块,因为生产者/
消费者
场景
的
运行速度与最慢
的
组件一样快。限制或阻塞生产者是,而不是,因为我们
的
应用程序
为
消费者
提供了足够
的
时间,让他们稍后能够赶上。我
使用
的
是具有最大
容量
的
Th
浏览 4
提问于2016-05-02
得票数 5
回答已采纳
1
回答
使用
多个线程(在一个池中)访问
BlockingQueue
不能像预期
的
那样并行工作
java
、
thread-safety
、
java-threads
、
blockingqueue
其中一个Schedular是将一个随机数放入队列,延迟
1
秒,我实现了另一个包含10个线程池
的
Schedular,以便从消息队列中调用take()。重要
的
是我正在尝试实现
的
场景是,在从队列中取出单个项目后,线程等待20秒(线程睡眠),我
的
理解是线程池中
的
其他9个线程将开始并行工作,而第一个线程等待20秒(其他线程也将等待20秒),但事实并非如此。池中
的
其他线程似乎根本没有启动。我是BlockingQueues
的
新手,任何帮助都将不胜感激。 我
的<
浏览 4
提问于2020-11-19
得票数 0
2
回答
死锁同时向
BlockingQueue
添加()和带()元素
java
、
multithreading
、
threadpool
、
executorservice
、
blockingqueue
我正在
使用
java.util.concurrent包并
使用
它
的
接口/类来了解它们是
如何
工作
的
。我创建了一个
BlockingQueue
实例(ArrayBlockingQueue集成)。创造了50名
消费者
和50名Rannable类型
的
生产商。然后,
使用
Executors.newFixedThreadPool(4)创建了一个大小
为
4
的
线程池,并将我
的
所有
消费者
浏览 5
提问于2017-10-22
得票数 1
回答已采纳
1
回答
从主线程共享对象和控制线程执行
java
、
concurrency
、
mutual-exclusion
我正在试着
解决
相当简单
的
问题
。我有一个主线程,它绘制一个框架和另一个线程(FrameThread),它每次都准备这个框架。两个线程应该共享相同
的
MyFrame对象。drawFrame( frame_engine.getFrame() ); } 所以我
的
目标是: FrameThread在后台执行,并在frame准备好后立即停止。我是Java
的
新手,我觉得有更好更安全
的
方法来实现它。你能给我一个建议吗?谢谢。
浏览 2
提问于2012-02-19
得票数 0
回答已采纳
1
回答
如何
消除Rox NIO教程中
的
竞争条件
java
、
nio
、
race-condition
我一直在
使用
教程来实现一个
使用
socket IO
的
简单文件传输客户端/服务器。我更改了响应处理程序,将多个读取作为一个文件
的
一部分接受,因为我将处理大文件,可能高达500MB。= -
1
){}} private synchronized int waitForFileChunk(FileOutputStream fos) throws IOExceptionlength < NioClient.READ_SIZE)//Probably
浏览 0
提问于2012-01-11
得票数 1
回答已采纳
4
回答
BlockingQueue
与TransferQueue
的
区别
java
、
concurrency
、
jsr166
我对
BlockingQueue
/LinkedBlockingQueue和jsr166y和Java7
的
新传输队列/LinkedTransferQueue类型之间
的
区别感到有点困惑
浏览 0
提问于2011-09-06
得票数 57
回答已采纳
3
回答
生产者
使用
者
使用
阻塞队列
java
、
multithreading
我已经开始学习线程,并尝试
使用
JDK5.0中引入
的
并发包在Java中
解决
生产者
消费者
问题
,我编写了以下代码:import<Integer> objqueue; objqueue = obj; @Override<Integer> o
浏览 1
提问于2015-02-03
得票数 0
回答已采纳
1
回答
在少数情况下,我
的
消费者
可以(显然)成为生产者吗?
java
、
producer-consumer
、
blockingqueue
我正在
使用
ExecutorService和
BlockingQueue
解决
使用
生产者-
消费者
问题
的
事务轮询案例。我有一个交易列表,我想要验证这些交易并采取行动。我正在获得一个新
的
交易,以不断验证。因此,我将验证,如果它是假
的
,并且时间大于30秒,我将放弃它。基本上,我只想在数据项是可
使用
的
时候
使用
。 首先,这种方法好吗?或者我应该尝试一些其他
的
解决
浏览 13
提问于2019-08-16
得票数 1
3
回答
多线程同步在Java中不起作用
java
、
multithreading
我正在尝试一个用java实现多线程
的
例子。在Java Complete reference第7版中有一个关于多线程同步
的
例子。该示例运行良好。但是,当我稍微添加一行代码来创建同一个类
的
另一个线程时,这并不起作用。请告诉我为什么会发生这样
的
事情。下面给出了示例。下面的代码是生产者和
消费者
的
典型例子。class PCFixed { Q q = new Q(); Prod
浏览 1
提问于2013-04-13
得票数 0
2
回答
使用
唯一id创建多个线程(线程不重叠)
java
、
multithreading
、
loops
、
producer-consumer
更新import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.
BlockingQueue
class ProducerConsumerExa
浏览 4
提问于2021-04-29
得票数 2
回答已采纳
2
回答
具有多个显示器
的
BlockingQueue
设计
java
、
synchronization
、
blocking
、
monitor
、
java.util.concurrent
我正在编写一个
BlockingQueue
,我想知道其他实现
如何
解决
这个
问题
:
BlockingQueue</
浏览 2
提问于2011-10-29
得票数 2
回答已采纳
1
回答
带有依赖注入错误
的
生产者/
使用
者模式
java
、
multithreading
、
dependency-injection
、
cdi
、
producer-consumer
继续这个
问题
,我有个情况..。我正在
使用
生产者/
消费者
模式来
使用
对象列表。“我
的
类
消费者
”是Runnable
的
实现。public class MYConsumer implements Runnable{ private MYService myService; public MYConsumer (
Blockin
浏览 0
提问于2018-08-31
得票数 0
回答已采纳
4
回答
在
使用
者等待和tomcat关闭时,Java -停止线程
java
、
multithreading
、
tomcat
、
thread-safety
在init中,我创造了生产者和
消费者
。consumer = new MyThread();运行
的
方法如下:public void run() { if (queue.isEmpty()) else }那我就有毁灭
的
方法了将关机设置
为
true,并
使用
.join consumer
浏览 7
提问于2015-12-08
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
线程池(上)
如何用Java编写代码解决生产者消费者问题?
CompletionService的用法及解析
如何改变电脑IP地址限制投票打榜
说说队列Queue
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券