如何在Spring Boot中使用ArrayBlockingQueue？我已经配置了如下队列：public class MessageQueueConfig {
public ArrayBlockingQueue arrayBlockingQueue() {
ArrayBlockingQueue<Message> arrayBlockingQueue = new ArrayBlockingQueue<>(5
浏览 5提问于2021-09-21得票数 0
> record, ArrayBlockingQueue<ConsumerRecord> arrayBlockingQueue) throws InterruptedException, ExecutionException(record); }));}
我向监听器添加了一个参数ArrayBlockingQueue，我希望它将Kafka的消息添加到监听器中。我遇到的问题是，我不知道如何将一个ArrayBlockingQueue传递给侦听器，
浏览 1提问于2018-09-17得票数 0
回答已采纳
1回答
使用双队列的Java堆栈
、、、、
当我尝试推入一些整数时，我得到了运行中的经验，希望有人能告诉我为什么现在使用这个main:这是我的实现： ArrayBlockingQueue <Integer> queue1; public StackWithQueue(int size){
this.size =
浏览 0提问于2015-10-14得票数 0
我想升级到apache.commons.collections4，但是有些类如CircularFifoBuffer和UnboundedFifoBuffer被删除了什么是正确的替代这类课程？或许还有另外一种选择：
用MinMaxPriorityQueue替换缓冲区本身也不是线程安全，但幸运的是，番石榴以Queues.synchronizedQueue(队列q)调用的形式为线程安全提供了包装器。由于我们已经在其他地方使用番
浏览 10提问于2020-06-11得票数 2
回答已采纳
(在我们的产品中发现了这段代码)
我读到了关于ArrayBlockingQueue的文章，发现它是有界的和被阻塞的。现在，如果我们使用- BlockingBuffer.decorate(new BoundedFifoBuffer() -看起来类似于ArrayBlockingQueue。
浏览 2提问于2014-03-18得票数 0
回答已采纳
我使用的是一个ArrayBlockingQueue，但有时它会变得完全，并阻止向其中添加其他对象。public class MyArrayBlockingQueue<E> extends ArrayBlockingQueue<
浏览 7提问于2016-12-08得票数 2
1回答
我遇到了一个问题，Spring不能自动生成ArrayBlockingQueue类型的参数化成员变量。下面是java代码：public class SomeController @Autowired}<bean id="myQueue" class="java.util.concurrent.ArrayBlockingQue
浏览 4提问于2011-10-05得票数 6
回答已采纳
4回答
Java数组/列表索引大小
、、、、
我想知道如何表达以下内容:我的ArrayBlockingQueue列表有10个条目(0-9)的空间；我的问题是，我该如何编写或表达它？"ArrayBlockingQueue有十个指数“，或者"ArrayBlockingQueue有九个指数”，我说得对吗？谢谢。
浏览 0提问于2011-03-03得票数 0
回答已采纳
我需要为我的爬虫“序列化”一个包含domanis名称(Strings(对象))的大型BlockingQueue( 10_000) --例如，如果我停止它，或者它会意外发生--这将有助于不爬行已经完成的操作。做这件事最好的方法是什么？在NET中，我已经将二进制序列化用于这样的任务(例如，protobuf )(它更快、更序列化，信息可视化对于理解-so并不重要，而不是必需的XML )。但是如何在java中做到这一点呢？你可能是样本的推荐人吗？
浏览 0提问于2014-09-08得票数 4
回答已采纳
downloadedBlockingQueue： private ArrayBlockingQueue<String> imgUrlsBlockingQueue;
public ImageDownloader(ArrayBl
浏览 2提问于2016-06-09得票数 2
回答已采纳
当池中的线程数超过10个时，任务将放置在ArrayBlockingQueue中。但是如果任务是可以调用的呢？构造函数ThreadPoolExecutor不接受键入为可调用的ArrayBlockingQueue。那么，如何将任务添加到队列中呢？executorService = new ThreadPoolExecutor(2, 10, new ArrayBlockingQueue
浏览 7提问于2015-01-18得票数 0
回答已采纳
我对ArrayBlockingQueue进行了如下简单的测试： private ArrayBlockingQueue<Integer> queue;
浏览 1提问于2018-08-12得票数 2
回答已采纳
我一直在使用LinkedBlockingQueue，最近由于插入性能缓慢，我将其更改为ArrayBlockingQueue。在那之后，我的表现有了很大的提高。但是，我的代码有时会抛出内存不足的错误：ArrayBlockingQueue<String> s = new ArrayBlockingQueue<String>(Integer.MAX_VALUE);publ
浏览 2提问于2013-04-06得票数 2
你好，有人知道如何监视正在扩展ArrayBlockingQueue的类吗？例如，我想监视下面的MyBufferQueue类在属于java库的ArrayBlockingQueue类中，有以下方法： Objects.requireNonNull(E e)时，我在this.lock中得到一个Nu
浏览 4提问于2022-08-21得票数 1
回答已采纳
为了学习，我编写了以下代码，用于自定义线程池引用和编辑显示的代码( )import java.util.ArrayList;import java.util.concurrent.ArrayBlockingQueueThreadPoolService(int corePoolSize) { this.taskQueue = new <
浏览 0提问于2018-09-23得票数 1
回答已采纳
我有一个这样的课程。start方法将在另一个类(如预加载类)中调用。 private Thread m_thread;
return m_persistentQueue.size();
protected
浏览 4提问于2018-11-22得票数 0
我无法找到为什么JDK在LinkedBlockingQueue中使用ArrayBlockingQueue而不是Executors.newFixedThreadPool的好处。TimeUnit.MILLISECONDS,ArrayBlockingQueue因此，需要一些ArrayBlockingQueue无法实现的好处或额外的功能。
浏览 9提问于2016-02-14得票数 0
回答已采纳
4回答
我正在学习Java中一个更高级的主题，那就是多线程主题。package multithreading;
import java.util.concurrent.ExecutorService;import java.util.concurrent.TimeUnit;import ja
浏览 3提问于2016-03-25得票数 0
当我实例化ArrayBlockingQueue时，我还必须在其构造函数中放入int容量。同样的事情不适用于LinkedBlockingQueue。我感兴趣的是为什么？为什么它在这里是最优的，而不是在ArrayBlockingQueue？ArrayBlockingQueue不能像ArrayList那样在默认情况下具有初始容量吗？
浏览 1提问于2020-08-26得票数 0
回答已采纳
我正在为Android开发一个媒体播放器应用程序。我有两个线程:一个产生音频帧，另一个消耗这些帧。在Java中，我似乎找不到任何类提供与ArrayBlockedQueue类似的功能，但允许我动态地使项目列表更长/更短。然后我有了一个奇怪的想法:我能伪造它吗？我是否可以创建一个具有新大小的新ArrayBlockedQueue，并逐步复制当前在旧ArrayBlockedQu
浏览 4提问于2014-08-11得票数 0
回答已采纳
云服务器
ICP备案
即时通信 IM
云直播
实时音视频
腾讯云开发者
