java.util.concurrent 相关问题

Java包,包含在并发编程中常用的实用程序类。该软件包包括一些小的标准化可扩展框架,以及一些提供有用功能的类,以及其他繁琐或难以实现的类。

CyclicBarrier中的getNumberWaiting()不正确

我分析了jdk1.8中的代码,但是在其他jdk版本中可能存在相同的问题。假设以下代码中的party = 3 CyclicBarrier cb = new CyclicBarrier(3);各方= 3,计数> = 0,...

回答 1 投票 -1

如何等待runAsync完全完成可完成的将来?

此测试失败:包com.stackoverflow.demo;导入java.util.concurrent.CompletableFuture; import java.util.concurrent.ConcurrentLinkedQueue;导入java.util.concurrent.ForkJoinPool;导入...

回答 1 投票 0

使用ConcurrentHashSet时的线程安全引用分配

对DTO中ConcurrentHashSet的用法有些困惑。一次由多个线程访问此DTO。第一类公共类DonorPlanLogDTO {private Set person = ...

回答 1 投票 0

带有弱引用的ConcurrentHash映射

我陷入了一个问题,确实需要一些帮助才能完成此操作。我有一个ConcurrentHashMap,其中多个can线程可以同时存储或检索数据。解决这个问题...

回答 2 投票 0

如何在Java中的多个线程之间共享公共日志文件

我们能否在读写多个线程之间共享同一日志文件。首先像并发收集一样在Deque中转储消息,然后定期从deque中转储数据是一个好主意...

回答 1 投票 0

如何将不计数到零的CountDownLatch不中断地返回?

(为了后代,我熟悉了另一个问题,它的回答似乎暗示我正在观察的情况是不可能的:CountDownLatch是否受虚假唤醒影响?)我有一个...]]

回答 1 投票 3

如果使用者线程遇到异常,如何停止生产者线程

我有这种使用生产者的情况,我正在使用arrayblockingqueue。如果使用者线程遇到异常,如何停止生产者线程。我需要生产者停止等待队列为空。 i ...

回答 1 投票 0

高通量一个变量写在Java中8并发?

如果我有一个Java 8个程序是由多个线程读取和写入的一个简单的整数。如果我告诉应用程序需要支持高吞吐量读取和很少写 - 这个问题的答案...

回答 1 投票 3

Java中的按键阻塞Map

我正在处理一些第三方库代码,涉及创建昂贵的对象并在Map中缓存它们。现有的实现类似于lock.lock()try {Foo result = ...

回答 3 投票 8

在这个例子中,混淆了ConcurrentHashMap和HashMap行为之间的区别

我试图了解ConcurrentHashMap的工作原理。我找到了一个例子,但我无法理解它。这是它的代码:Map myData =新的HashMap (); ...

回答 1 投票 3

ThreadPoolExecutor - 如果池已满,我可以抛出异常

如果无法处理传入请求,是否可以抛出异常?所以,我有一些固定的线程池:private val executor:ThreadPoolExecutor = Executors.newFixedThreadPool(4)as ...

回答 2 投票 2

消费者正在等待使用Java ExecutorService运行

我有一个生产者与多个消费者样本。生产者将事件放入阻塞队列。消费者从队列中获取消息,然后将其插入到DB中。这工作了很多天。但是,......

回答 1 投票 1

为什么ConcurrentHashMap中的HashEntry是最终的?

我将在jdk 7中查看ConcurrentHashMap的源代码并且几乎没有问题。我已经在StackOverFlow上完成了有关CHM的所有问题,但找不到答案。是get()......

回答 1 投票 2

线程安全对象数组

我在Java中使用二维数组。但是现在,我想将这个类用于多线程。我怎样才能做到这一点?我知道如何进行线程安全功能(添加synchronized关键字)。如果...会发生什么

回答 2 投票 1

这个程序中同时存在什么错误?

我有一个奇怪的并发错误的程序。该程序的作用:每个EVENT_LOOP_PAUSE_DURATION_IN_MS执行事件循环。对于每个给定的任务执行处理器TaskProcessor每500毫秒......

回答 1 投票 0

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

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

回答 1 投票 3

java.util.concurrent.CompletableFuture中的异常传播

有两个代码片段。在第一个中,我们从任务中创建CompletableFuture,它始终抛出一些异常。然后我们对这个未来应用“特殊”方法,然后“接受”......

回答 1 投票 3

始终调用Spring自定义ThreadPoolTask Executor

我正在尝试将Spring上下文复制到Runnable / Callable任务以获取特殊情况。我希望其他线程在之前运行时运行。我已经阅读了如何在异步任务执行器中启用请求范围和...

回答 1 投票 0

ConcurrentHashMap完全安全吗?

这是来自JavaDoc的关于ConcurrentHashMap的一段话。它说检索操作通常不会阻塞,因此可能与更新操作重叠。这是否意味着get()方法不是线程...

回答 6 投票 44

在java中是否存在BlockingMap作为BlockingQueue?

我想要一个与BlockingQueue非常相似的BlockingMap数据结构。 BlockingQueue的take方法将在那里等待,直到元素可用。我想要...的get方法

回答 3 投票 16

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.