java.util.concurrent 相关问题

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

为什么调用 Java DelayQueue 的 take() 方法不会阻塞所有线程的整个数据结构?

我试图弄清楚 java.util.concurrent.DelayQueue 在多线程环境中如何工作。我看到这个数据结构内部使用了ReentrantLock,而且是一开始就获取的...

回答 1 投票 0

LeetCode 1116 Java并发问题,等待线程会重新访问之前的代码吗?

这是我解决问题的代码,工作正常,但是,当我更改synchronized语句下的while语句时,似乎任何在notifyall()之后获得锁的线程都会继续...

回答 1 投票 0

CompletableFuture 是如何运作的? [已关闭]

需要了解在没有执行者的情况下完成未来任务的见解。 这是我的示例代码 CompletableFuture.runAsync(() -> { 做一点事(); }); 这个任务怎么分配给三个...

回答 1 投票 0

当公共池不支持并行级别 >= 2 时,让 CompletableFuture 为任务创建单独的线程的意图

CompletableFuture 的 Java 文档指出: 所有没有显式 Executor 参数的异步方法都使用 ForkJoinPool.commonPool() 执行(除非它不支持并行级别...

回答 1 投票 0

是否无法向 ForkJoinPool 提供线程工厂或名称模式?

我想为工作窃取池使用的 ForkJoinPool 线程设置名称,由 ExecutorService newWorkStealingPool(int并行性) 或者 ExecutorService newWorkStealingPool() 所以...

回答 3 投票 0

Scala 等待 Future.sequence 的 Await.result,哪些 future 没有按时完成?

我有期货清单并等待 val listWithResult = Await.result(Future.sequence(listOfFutures), 10.分钟) 它失败了 java.util.concurrent.TimeoutException:期货在 [10 分钟后超时...

回答 1 投票 0

如何让可运行实例在一个线程中等待并由其他线程通知?

在下面的代码中,一个可运行实例正在等待获取通知。如何通过其他线程通知该线程我应该使用方法或另一个包含要通知的线程的类..我被卡住了...

回答 3 投票 0

异步任务日志中TraceId和Span为空

我在 springboot 中有一个 REST 端点,它使用 CompleteableFuture 调用外部 api 异步多个。在Completeablefuture.supplyAsync(() =>

回答 1 投票 0

为什么 AbstractQueuedSynchronizer 没有使 acquire() 独占?

文档说 acquire() 处于独占模式: // 以独占模式获取,忽略中断。 公共最终无效获取(int arg){ if (!tryAcquire(arg) && acquireQueued(addW...

回答 1 投票 0

尝试使用信号量时,只有一个线程执行

据我了解,java.util.concurrent.Semaphore 允许我指定一次可以有多少个线程使用资源。线程可以使用 Semaphore.acquireUninterruptically() 来消耗有限的numb...

回答 1 投票 0

为什么执行器服务提交的任务没有异步执行任务?

我正在尝试在我的 intellij 本地中使用异步 java。我的意图是,我将从 main 方法调用 calucalateAsync() 方法,然后将调试点放在 System.out.println("calculate

回答 1 投票 0

动态缩放线程数量的ExecutorService

我有一个工作单元列表,我想并行处理它们。每个单元工作时间为 8-15 秒,完全计算时间,无 I/O 阻塞。我想要实现的是拥有一个 ExecutorService ......

回答 2 投票 0

如何在java中使用TimeUnit

我正在尝试在java中使用TimeUnit,但它只是向我发送错误 我就是这样写的 导入 java.util.concurrent.TimeUnit ; 公共课任何东西{ 公共静态无效主(字符串[]参数){ ...

回答 2 投票 0

IntelliJ IDEA + JDK 21 java.util.concurrent 包的问题 - TimeUnit 类

当我尝试使用 java.util.concurrent 中的 TimeUnit 类时遇到问题。 Oracle JDK 21.0.1(配置如下)+ IntelliJ IDEA 2023.1.5(社区版)会发生这种情况 - 最新...

回答 1 投票 0

IntelliJ IDEA + JDK 21 java.util.concurrent 包问题 - TimeOut 类

当我尝试使用 java.util.concurrent 中的 TimeOut 类时遇到问题。它发生在 Oracle JDK 21.0.1(配置如下)+ IntelliJ IDEA 2023.1.5(社区版)- 最新

回答 1 投票 0

Java Exchanger 示例不起作用

我有以下代码。该代码创建两个分别带有消息“Hello”和“World”的可运行对象。 我希望这能与“World”交换“Hello”,但它不起作用。代码卡住了并且

回答 2 投票 0

Java ExecutorService:- 当事件发生时通知线程唤醒

我有一个 Manager 类,多个线程向其中注册自己(使用 UUID 为每个请求生成唯一标识符),提供要处理的有效负载并从

回答 2 投票 0

CountDownLatch - 理解await 和countDown

根据Javadoc: CountDownLatch 使用给定计数进行初始化。 wait 方法会阻塞,直到当前计数达到零。 这意味着在下面的代码中,因为我初始化了

回答 3 投票 0

带有背压的ExecutorService

我对 ExecutorService 有以下要求: 并发处理任务(线程)数量有限,最好是可配置的 当所有线程都被占用后,后续提交任务...

回答 2 投票 0

在应用程序中使用 Future 块 UI

在我的 Android 应用程序中,我想使用 java.util.concurrent 工具来进行返回值的操作(用于教育目的)。我读到 Future with Callable 可以用于此目的。我做了一个项目......

回答 1 投票 0

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