java.util.concurrent 相关问题

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

Spring cloud @HystrixCommand不代理在CompletableFuture.supplyAsync中调用的方法

我有一个spring组件bean,它包含一个由@HystrixCommand和fallbackMethod定义的方法methodA。 bean有另一个方法methodB通过CompletableFuture.supplyAsync调用methodA(......

回答 1 投票 0

使用Comparator的ConcurrentSkipListSet不会添加新的唯一值

我想要一个并行的字符串值集合,按长度排序最长 - >最短。这是我的代码(JAVA 8):private ConcurrentSkipListSet sortedSourceTypeNames = new ConcurrentSkipListSet&...

回答 1 投票 4

Java并发 - 任何人都可以帮助我输出。为什么列表是空的?

创建了2个在列表中插入值的任务。然后使用执行程序服务执行这些任务。最后尝试找出这些列表中的值。为什么值没有插入列表...

回答 1 投票 2

的CopyOnWriteArrayList(科瓦尔)

我从一些教程中理解了这个概念,只要我知道当一个线程在迭代列表时,其他线程就可以修改底层列表而我们不会得到ConcurrentModificationException(...

回答 2 投票 0

不安全的compareAndSwapInt与同步

我发现几乎所有高级同步抽象(如Semaphore,CountDownLatch,来自java.util.concurrent的Exchanger)和并发集合都使用Unsafe中的方法(如...

回答 1 投票 1

在UltimateQueue中,领导者究竟使用了什么?

我试图理解java.util.concurrent中的DelayQueue,但是领导者让我很困惑。首先,我们可以实现一个没有这样的领导者的DelayQueue:public boolean offer(E e){final ...

回答 1 投票 0

java 7/8中带有大小限制的linkedtransfer队列的任何替代方案?

为了实现生产者/消费者模式,我使用了LinkedTransferQueue。检查以下代码while(true){String tmp = new randomString(); if(linkedTransferQueueString.size()<...

回答 4 投票 1

我可以为subscribeOn方法和异步任务使用相同的执行程序

嗨,我有一个简单的问题,假设我有一个类如下:import lombok.Value; import java.nio.file.Path; @Value类ImageResizeRequest {private DownloadedImage downloadedImage; ...

回答 2 投票 0

将线程注册到Phaser

我正在学习Phaser。在这样做的同时,我遇到了一个问题。下面是我的代码,公共类RunnableTask实现了Runnable {private Phaser phaser;上市 ...

回答 1 投票 1

线程安全实现max

我需要为Web服务器实现全局对象收集统计信息。我有统计单例,它有方法addSample(长样本),随后调用updateMax。这必须......

回答 5 投票 21

Java从ConcurrentHashMap中删除特定项

使用remove()方法好吗?我读过一篇文章,说明同步还没有添加到remove方法中。如何从ConcurrentHashMap中正确删除特定项?示例代码:...

回答 3 投票 9

Java ExecutorsService提交FutureTask get on Future返回null

我有这个片段。 final ExecutorService executor = Executors.newFixedThreadPool(3); final Runnable runnable =() - > {System.out.println(“Inside runnable run method”);};最终可调用&...

回答 2 投票 2

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