java.util.concurrent 相关问题

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

afterExecute 方法未调用在传递给 RabbitMQ Spring SimpleRabbitListenerContainerFactory 的 CustomThreadPoolExecutor 中定义的

Spring-Rabbitmq SimpleRabbitListenerContainerFactory 是使用 CustomThreadPoolExecutor 定义的。 @豆 公共SimpleRabbitListenerContainerFactoryrabbitListenerContainerFactory(最终ConnectionF...

回答 1 投票 0

如何与 Kotlin 中的并发集合交互?

从我使用的库中我得到了 ConcurrentMap。我想获取它的密钥作为 Set。 如何以线程安全的方式做到这一点(因为 Kotlin 集合 API 是线程不安全的)?

回答 1 投票 0

Java 中丢失信号

此代码会导致丢失信号吗?如果是,那么如何? 私有对象锁 = new Object(); 私有布尔条件Met = false; 公共无效 waitForCondition() 抛出 InterruptedException { ...

回答 1 投票 0

ExecutorCompletionService?如果我们有 invokeAll 为什么还需要一个?

如果我们使用 ExecutorCompletionService,我们可以将一系列任务作为 Callable 提交,并以队列的形式与 CompletionService 交互来获取结果。 但还有

回答 4 投票 0

Executor Service 的 shutdown 和 shutdownNow 的区别

我想知道 shutdown() 和 shutdownNow() 关闭执行器服务的基本区别? 据我了解: shutdown() 应该用于正常关闭,这意味着......

回答 3 投票 0

jmeter 中的负载测试正在使用多个线程生成重复的连续 ID

场景 我正在使用其 API 的三个请求在系统中创建一些记录。在第一个请求中,我需要发送 ID,出于测试和跟踪目的,我使用连续号码

回答 1 投票 0

并发循环执行失败

我正在尝试编写负载均衡器的内存中实现,该实现将有一个 get() 方法以循环模式返回实例,我需要它在并发环境中正确运行...

回答 1 投票 0

如何使用 AtomicBoolean 进行阻塞和等待

我正在寻找一种暂停线程的方法。 我首先有效地使用布尔标志(称为“暂停”),并用 while 循环包装检查(暂停)。 在 while 循环内有一个 Thr...

回答 5 投票 0

ConcurrentHashMap 读、写和清除()

假设有3个读线程和1个写线程。 写入线程调用map.clear()。会造成什么异常或影响?

回答 3 投票 0

有条件地设置AtomicReference

我想有条件地、原子地更新(或者如果当前为空则设置)基于当前值的谓词的 AtomicReference。 我希望存在这样的事情: /** *

回答 2 投票 0

等待回调而不暂停调用线程。我这样做对吗?

公共类Threadz实现Callable{ 私有布尔标志= false; @覆盖 公共字符串调用()抛出异常{ // TODO 自动生成的方法存根 ...

回答 2 投票 0

Java多线程并发问题不会出现并自动同步

我正在尝试测试,出现多线程并发问题。 我期望的是结果应该小于 0(并非总是但有时),因为它不同步。 但是下面的测试失败了...

回答 1 投票 0

Java多线程并发问题不会出现并自动同步

我正在尝试测试,出现多线程并发问题。 我期望的是结果应该小于 0,因为它没有同步。 但下面的测试失败了。 导入静态 org.asse...

回答 1 投票 0

是使用invokeAll还是submit-java Executor服务

我有一个场景,我必须为同一个可调用对象异步执行 5 个线程。据我了解,有两种选择: 1)使用提交(可调用) ExecutorService 执行器服务 =

回答 4 投票 0

Java Flow.Subscriber - 如何取消订阅?

我正在使用 JDK 9 Flow API 创建一个用户事件系统,所以我有一个房间(实现 Flow.Subscriber),它可能有很多用户,每个用户都可以在...

回答 1 投票 0

在 SCHEDULED 状态下取消 JavaFX 服务

我正在尝试使用 cancel() 方法取消我的 JavaFX 服务。 在调用 cancel() 之前,我检查 Worker 状态。 System.out.println(service.getState()); System.out.println(service.cancel()); ...

回答 2 投票 0

单元测试 CompletableFuture 异常

这是我的第一篇文章,我是 CompletableFuture 的初学者,我想在使用 CompletableFuture.get() 时测试异常(InterruptedException 和 TimeoutException)。 我的代码: 完整的未来...

回答 1 投票 0

Java 17 Fork join池限制池中线程数

在 java 17 中,我们看到与旧的 java 版本(在我的例子中是 java 8)相比,创建了更多的线程(尽管不是同时执行)。虽然线程本身可能不是一个 h...

回答 1 投票 0

CompletableFuture.supplyAsync() 是否多余,以防它不修改传入值?

在并发编程课程中,我遇到了以下示例代码: @测试 void PromiseTestCompose2() 抛出异常 { CompletableFuture future1 = CompletableFuture .

回答 1 投票 0

CompletableFuture.supplyAsync() 在不修改传入值的情况下是否冗余

在学习并发编程课程时,我遇到了以下示例代码: @测试 void PromiseTestCompose2() 抛出异常 { CompletableFuture future1 = CompletableFuture .

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.