blockingqueue 相关问题

队列数据结构，在检索元素时等待（暂停当前线程）队列变为非空，并且在存储元素时队列中的空间变为可用。

java BlockingQueue没有阻塞偷看？

我有一个阻塞队列的对象。我想写一个阻塞的线程，直到队列中有一个对象。与BlockingQueue.take（）提供的功能类似。但是，因为我不...

java queue peek blockingqueue

回答 7 投票 31

DelayQueue意外行为。 DrainTo只从队列中删除1个已过期的项目

我想迭代我的DelayQueue中未过期的元素。类Transaction实现Delayed，并有一个字段时间戳，表示事务的时间戳...

java multithreading priority-queue java.util.concurrent blockingqueue

回答 1 投票 3

如何使用带有BlockingQueue的构造函数创建ThreadPoolExecutor 作为一个论点，列入Callables？

ThreadPoolExecutor的构造函数具有BlockingQueue的类型参数作为Runnable。假设我有一个像ThreadPoolExecutor一样声明的ThreadPoolExecutor customThreadPool = new ...

java threadpoolexecutor callable blockingqueue

回答 1 投票 1

在ThreadPoolExecutor中使用LinkedBlockingQueue（Integer.MAX_VALUE）时发生RejectedExecutionException

我正在将ThreadPoolExecutor与LinkedBlockingQueue（Integer.MAX_VALUE）一起用于多个任务，但是为什么在websphere中的2000个任务中提交（可调用任务）时它会抛出RejectedExecutionException？ ...

exception concurrency java-8 websphere blockingqueue

回答 1 投票 0

为什么在LinkedBlockingQueue的put（）中有一个while循环

public void put（E e）throws InterruptedException {if（e == null）throw new NullPointerException（）; int c = -1;节点 node = new Node （E）;最终的ReentrantLock putLock = ...

java concurrency java.util.concurrent blockingqueue

回答 3 投票 1

如何正确终止阻塞的线程（Lparallel Common Lisp）

在Lparallel API中，终止所有线程任务的推荐方法是使用（lparallel：end-kernel）停止内核。但是当一个线程阻塞时 - 例如，（pop-queue queue1）等待...

multithreading common-lisp blockingqueue

回答 1 投票 3

阻止队列失序

我有一个包含整数的简单阻塞队列。在多线程环境中，我正在使用并在队列的后面添加元素。 BlockingQueue的 test = new ...

java multithreading data-structures thread-safety blockingqueue

回答 1 投票 0

Spring Autowired Shared Queue NullPointerException

我第一次使用Spring并且正在尝试实现一个共享队列，其中一个Kafka监听器将消息放在共享队列上，一个ThreadManager最终会做一些事......

spring spring-boot apache-kafka autowired blockingqueue

回答 2 投票 1

使用阻塞队列的对象池在死锁中运行

我有一个在payara 5中运行的java应用程序。我需要汇集一些我的bean将使用的引擎对象（来自库）。创建引擎需要在单独的线程中完成。因此......

java glassfish pool blockingqueue payara

回答 1 投票 0

corePoolSize = 0如何为ThreadPoolExecutor工作？

ExecutorService.newCachedThreadPool（）的定义是public static ExecutorService newCachedThreadPool（ThreadFactory threadFactory）{return new ThreadPoolExecutor（0，Integer.MAX_VALUE，...

java multithreading executorservice threadpoolexecutor blockingqueue

回答 1 投票 2

弹簧批处理中的“ItemReader”可以等到数据可用于处理类似阻塞队列的时间点吗？

目前我遵循以下策略来一步处理物品。 TaskletStep processingStep = stepBuilderFactory.get（getLabel（）+“ - ”+ UUID.randomUUID（）。toString（））...

multithreading spring-batch blockingqueue

回答 1 投票 0

在UltimateQueue中，领导者究竟使用了什么？

我试图理解java.util.concurrent中的DelayQueue，但是领导者让我很困惑。首先，我们可以实现一个没有这样的领导者的DelayQueue：public boolean offer（E e）{final ...

java multithreading concurrency java.util.concurrent blockingqueue

回答 1 投票 0

blockingqueue 相关问题

最新问题