java.util.concurrent 相关问题

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

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

Condition#await(long, TimeUnit) 的 2 个参数版本的惯用语

使用 Condition#await(long, TimeUnit) 的 2 个参数版本时处理虚假唤醒的惯用方法是什么 我理解零参数版本: 导入 java.util.concurrent.Execut...

回答 1 投票 0

Jenkins 并发构建归档工件

当我在詹金斯中触发并发构建时,只有稍后完成的构建工件不会存档。 它说, 归档工件 ‘workspace-2/results*/’ 不匹配任何内容,但 '' 匹配。也许...

回答 1 投票 0

如果是独立任务,使用子线程或使用消息队列(kafka)哪个更好

我有一个用例,我正在迭代列表,并且对于每个元素我正在执行一项任务。 但我不能同步执行此操作,因为代码是 Kafka 消费者的一部分,并且运行时不能......

回答 1 投票 0

Java反射的set操作如何保证线程安全?

使用Java反射时,Field public void set(Object obj, Object value) 是线程安全的吗?如果不是线程安全的,那set的原子性怎么保证呢? 很少写,经常读,读...

回答 1 投票 0

ConcurrentHashMap - 我们可以从 Transfer() 中删除 i >= n 吗?

相关: ConcurrentHashMap的传递方法中,我不明白这两个条件“i >= n”和“i + n >= nextn”的含义 我正在调查...

回答 1 投票 0

什么或谁应该中断线程?

Goetz 在他的《JCIP》一书中说道: 因为每个线程都有自己的中断策略,所以除非您知道中断对该线程意味着什么,否则不应中断该线程。 为什么...

回答 4 投票 0

ComputeIfAbsent 错误的地图大小

我已经尝试了下面的代码,以便为每个 jj 提供一个唯一的 id。 据我所知,computeIfAbsent 是线程安全的,但是: public static void main(String[] args) 抛出 InterruptedException { ...

回答 2 投票 0

避免 AtomicReference 中易变值的成本

Thread 1 -> 计算一个值 MyObject 并存储在 AtomicReference< MyObject>> 线程 2 -> 有时需要线程 1 存储的 MyObject 的值 查看 AtomicReference::se...

回答 0 投票 0

ANR 崩溃(sun.misc.Unsafe.park(本地方法))

main(定时等待):tid=1 systid=22386 在 sun.misc.Unsafe.park(本机方法) 在 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:230) 在 kotlinx.coroutines.BlockingCorou...

回答 1 投票 0

在 Java 中创建并发集合的浅表副本

我想创建一个并发集合的浅拷贝,把它变成一个常规集合。这样做有问题吗: ledger = new ConcurrentLinkedDeque<>(); // 这个 l...

回答 3 投票 0

为什么调用 ForkJoinTask.join() 而不是阻塞线程而不是像预期的那样从工作窃取机制中窃取工作

我有一个不对称拆分的递归任务。它不是分成两半,而是咬住一部分它可以执行的工作,然后分叉其余的工作。这种情况不会与

回答 1 投票 0

更好的 CompletableFuture 方法 acceptEither 与 acceptEitherAsync 有什么区别?

例如- CompletableFuture.supplyAsync(stage1).acceptEither(stage2, 消费者); stage1 和 stage2 应该在上面的代码中并行运行,因为它使用的是 acceptEither 如果我换成

回答 1 投票 0

CompletableFuture thenApply 在单独的线程中运行,而不是在调用者线程中运行?

当我执行 CompletableFuture 的 thenApply 方法时,此方法的执行发生在 ForkJoinPool 线程中,而不是调用者(主)线程中。为什么会这样?这个结果即使用叉子

回答 1 投票 0

为什么jdk中没有ConcurrentLinkedHashMap类?

这个问题直接来自我之前在 SO 中的问题。我认为我的第二个问题的答案是否定的。所以我想明白为什么java.util中没有ConcurrentLinkedHashMap

回答 3 投票 0

Springboot - 两个用户在调用与外部 API 交互的 EndPoint 时发生冲突

所以我有一个编译器微服务。该服务的主要职责是编译用户发送的代码片段。这是控制器类。 包 codenemy.api.Compiler.Controller; 进口

回答 0 投票 0

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