blockingqueue 相关问题

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

我不知道Sun为什么要写这样的代码，这里是示例（JDK版本：1.6）：示例1： java.util.concurrent.PriorityBlockingQueue#offer(E e): 公共布尔报价(E e) { 最终的 ReentrantLoc...

java number-formatting java-6 blockingqueue

回答 2 投票 0

什么时候更喜欢 LinkedBlockingQueue 而不是 ArrayBlockingQueue？

什么时候更喜欢 LinkedBlockingQueue 而不是 ArrayBlockingQueue？当以下情况时，LinkedBlockingQueue 和 ArrayBlockingQueue 使用哪种数据结构：您想要高效的读写应该有...

java multithreading concurrency blockingqueue

回答 3 投票 0

Java PriorityBlockingQueue 阻塞行为

从我看到的文档中， take() 方法会阻塞，直到元素变得可用。还有其他情况可能会阻塞吗？我的意思是，是否有一种可能的情况，当队列...

java priority-queue blockingqueue

回答 1 投票 0

等到阻塞队列已满

我正在寻找一种同步多个异步操作的方法。我想使用大小等于我的操作的 BlockingQueue，但是我可以等谁直到队列已满？我正在寻找

java multithreading synchronization blockingqueue

回答 5 投票 0

如何阻塞直到BlockingQueue为空？

我正在寻找一种阻塞方法，直到 BlockingQueue 为空。我知道，在多线程环境下，只要有生产者往BlockingQueue中放入item，就可能出现这种情况...

java concurrency blockingqueue

回答 6 投票 0

多线程如何处理BlockingQueue

如何在 BlockingQueue 上使用多线程处理数据（Consumer）？我正在按照此处所述实施生产者和消费者问题 https://javarevisited.blogspot.com/2012/02/producer-consumer-...

multithreading blockingqueue forkjoinpool linkedblockingqueue

回答 0 投票 0

如何在没有内存分配的情况下轮询（）并从 ArrayBlockingQueue 中删除项目

我正在尝试轮询 ArrayBlockingQueue 以获取项目：公共无效运行（）{ 而（真）{ 如果 (Thread.currentThread().isInterrupted()){ 关闭附加程序（）； ...

java garbage-collection blockingqueue

回答 0 投票 0

Java BlockingQueue与多个消费线程不公平

我正在使用(java)LinkedBlockingQueue创建一个资源池，其中的资源元素是等价的，属于一个池，它们的顺序是无所谓的。

java multithreading blockingqueue linkedblockingqueue

回答 1 投票 1

Scala线程池 - 并发调用API的方法

我有一个用例，在databricks中，一个API调用必须在一个URL的数据集上进行。这个数据集有大约100K条记录。我在Scala中做了实现并运行了......

scala apache-spark functional-programming databricks blockingqueue

回答 1 投票 1

为什么ArrayBlockingQueue构造函数使用ReentrantLock来提高可见性？

该代码来自ArrayBlockingQueue，JAVA8。注释说：仅出于可见性而锁定，而不是相互排斥。 final Object []个项目； int putIndex;整数计数公共ArrayBlockingQueue（...

java multithreading concurrency thread-safety blockingqueue

回答 2 投票 2

在queueCapacity为0的情况下，Spring Boot线程池执行程序REST模板行为，这会降低REST API应用程序的性能

我陷入了一个奇怪的问题，无法找出其根本原因。这是我的其余模板线程池执行程序：connectionRequestTimeout：60000 connectTimeout：60000 socketTimeout：...

spring-boot resttemplate java.util.concurrent threadpoolexecutor blockingqueue

回答 1 投票 0

读取Java中已有10分钟的消息

[我正在尝试实现一个生产者和消费者。生产者将继续将消息推入队列的地方。但是，尽管消费者只需要在30分钟后阅读这些消息即可...

java queue blockingqueue

回答 1 投票 0

Scala线程池-同时调用API

我在数据块中有一个用例，其中对URL的数据集进行了API调用。数据集约有10万条记录。允许的最大并发为3。我在Scala中进行了实现，然后运行...

scala apache-spark functional-programming databricks blockingqueue

回答 1 投票 1

java中的您自己的实现队列

我知道这个问题以前曾被问过很多次，但我只是想不出关于互联网之类的例子的技巧。这两个解决方案都检查...

java multithreading synchronization java.util.concurrent blockingqueue

回答 4 投票 14

Java-BlockingQueue冻结多线程应用程序

我正在制作一个包含两个线程的应用程序：其中一个将值写入LinkedBlockingQueue，另一个正在读取。我正在使用ScheduledExecutorService在某些...中运行此操作...

java-8 concurrency blockingqueue linkedblockingqueue

回答 1 投票 1

可调整大小的Java BlockingQueue

所以我在生产者/消费者类型的应用程序中使用固定大小的BlockingQueue [ArrayBlockingQueue]，但是我希望用户能够即时更改队列大小。问题是没有...

java concurrency blockingqueue

回答 3 投票 9

BlockingQueue-一个生产者多个消费者

我有三个线程。线程1（T1）是生产者，它生成数据。线程2和3（分别为T2，T3）分别等待T1的数据在单独的循环中进行处理。我正在考虑共享一个...

java multithreading thread-safety producer-consumer blockingqueue

回答 1 投票 0

使用Java中的任务执行程序将一千万个记录插入DB中

我的要求是加密表的个人标识列。为此，我编写了一个小代码，该代码分批选择数据并将其插入具有很少额外列的新表中。 ...

java mysql spring java-threads blockingqueue

回答 1 投票 1

被异步通知具有可用项目的BlockingQueue

当某些BlockingQueue有要提供的项目时，我需要异步通知对象。我已经在Javadoc和Web上搜索了一个预制的解决方案，然后我得到了一个（也许很幼稚）...

java concurrency blockingqueue

回答 3 投票 11

连续将Runnable任务提交给ExecutorService，直到工作完成，并获取java.util.concurrent.RejectedExecutionException

我的多线程类应该对ClassA类的许多对象执行三种操作-operation1，operation2和operation3，其中每种类型的操作都取决于...

java threadpool producer-consumer java.util.concurrent blockingqueue

回答 1 投票 1

blockingqueue 相关问题

最新问题