- 921. Minimum Add to Make Parentheses Valid 使括号有效的最少添加
- 915. Partition Array into Disjoint Intervals 分割数组
- 932. Beautiful Array 漂亮数组
- 940. Distinct Subsequences II 不同的子序列 II
Guava 是托管在 Github.com 上的流行的 Google 开源的 Java 线程池库。
Guava 包含了许多有用的并发类,同时还包含了几个方便的 ExecutorService 实现,但这些实现类都无法通过直接实例化或子类化来创建实例。取而代之的是提供了 MoreExecutors 助手类来创建它们的实例。
为了将Google Guava 库包含进当前的项目中,需要将下面的依赖项添加到 Maven pom 文件中。
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>26.0</version>
</dependency>
你可以在 Maven 中央仓库 中找到最新版本的 Guava 库
有时候,我们希望在当前线程或线程池中执行任务,具体在哪里取决于某些条件。这种情况下,你应该会更喜欢使用单个 Executor 接口,且只需切换实现即可。
虽然将当前线程中的任务的 Executor 或 ExecutorService 的提取出来单独实现并不困难,但它仍然需要编写一些样板代码。
值得庆幸的是,Guava 为我们提供了预定义的实例。
下面的范例演示了如何在同一个线程中执行任务。简单起见,提交的任务会将当前线程休眠 500 毫秒并阻塞当前线程,并在执行的调用完成后让结果立即可用
Executor executor = MoreExecutors.directExecutor();
AtomicBoolean executed = new AtomicBoolean();
executor.execute(() -> {
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
executed.set(true);
});
assertTrue(executed.get());
directExecutor() 方法返回的实例实际上是一个静态单例,因此使用此方法根本不会在对象创建上带来任何开销。
你应该更喜欢使用此方法来访问 MoreExecutors.newDirectExecutorService(),因为该 API 会在每次调用时创建完整的执行程序服务实现。
另一个常见问题是: 在线程池仍在运行其任务时关闭虚拟机。即使采用了取消机制,也无法保证任务执行良好,并在执行程序服务 ( Executor )关闭时停止工作。这可能会导致 JVM 在任务继续工作时无限期挂起。
为了解决这个问题,Guava 引入了一系列已经实例化好的执行器 ( Executor ) 服务。它们是守护线程模式,但会与 JVM 一起终止。
这些执行器服务还提供了 Runtime.getRuntime().addShutdownHook() 方法用于添加一个关闭钩子,用于设置 VM 在放弃挂起的任务之前等待一段预配置的超时时间。
下面的示例中,我们提交了一个无限循环的任务,我们使用了包含 100 毫秒超时时间的已经存在的执行程序服务来运行任务,并在超过配置的超时时间之后终止 VM 。如果没有 exitingExecutorService ,此任务将导致 VM 无限期挂起。
ThreadPoolExecutor executor =
(ThreadPoolExecutor) Executors.newFixedThreadPool(5);
ExecutorService executorService =
MoreExecutors.getExitingExecutorService(executor,
100, TimeUnit.MILLISECONDS);
executorService.submit(() -> {
while (true) {
}
});
监听装饰器允许我们封装 ExecutorService 并在提交任务时返回 ListenableFuture 实例而不是简简单单的 Future 实例。
ListenableFuture 接口扩展自 Future 接口,并添加了一个新方法 addListener(),该方法用于添加在将来完成时调用的侦听器。
一般情况下,我们很少直接使用 ListenableFuture.addListener() 方法,而是使用 Futures 类提供的许多辅助方法。例如,通过Futures.allAsList() 方法,我们可以在单个 ListenableFuture 中组合多个 ListenableFuture 实例,并会在这些实例在成功完成后将所有的 futures 合并并返回结果。
ExecutorService executorService = Executors.newCachedThreadPool();
ListeningExecutorService listeningExecutorService =
MoreExecutors.listeningDecorator(executorService);
ListenableFuture<String> future1 =
listeningExecutorService.submit(() -> "简单");
ListenableFuture<String> future2 =
listeningExecutorService.submit(() -> "教程");
String greeting = Futures.allAsList(future1, future2).get()
.stream()
.collect(Collectors.joining(""));
assertEquals("DDKK.COM 弟弟快看,程序员编程资料站", greeting);
这个问题不太可能帮助任何 future 的访客;它只与一个小地理区域、一个特定时刻或一个非常狭窄的情况相关,而这些情况通常不适用于互联网的全局受众。如需帮助使这个问题更广泛地适用,visit the
我有: data class Edge(val spec: String, val weight: Int) private val graph: SortedSetMultimap = TreeMu
鉴于使用以下代码创建的 Guava 缓存,如果未设置,是否有最大缓存大小? LoadingCache loadingCache = CacheBuilder.newBuilder().build(ne
我需要向 Guava Multimap 添加一个键,其中一个空集合作为值。我该如何做到这一点? 我试过这个: map.put( "my key", null ); 但是调用 get() 会返回一个包含
我刚刚遇到这样的代码: ExecutorService executorService = MoreExecutors.sameThreadExecutor(); for (int i = 0; i
我使用的是来自 Google Collections 的 com.google.common.collect.PrimitiveArrays,但是我在 Guava 中找不到它,是否已重命名?我在哪里可
当前,我正在使用以下代码在映射中创建过滤器以匹配并提供过滤后的结果集列表。 final Map filteredMap = Maps.filterKeys(mymap, Predicates.cont
当我在 app/build.gradle 中使用 implementation 'com.google.firebase:firebase-inappmessaging-display:17.2.0'
Google Guava Cache 文档指出: Refreshing is not quite the same as eviction. As specified in LoadingCache.
Guava 的 ImmutableList.Builder 的线程安全保证是什么? javadocs 没有说。 最佳答案 虽然 Guava Immutable 类是线程安全的,但它们的构建器不是。对于
目前我在我的应用程序中使用 guava EventBus 方法。监听器尝试做一些工作,如果失败,事件应该回到总线并重新发送。 我的问题是:如果我的应用程序出现故障(执行关闭)怎么办?它会在总线上发送剩
是否可以使用现有的 java 静态方法作为开箱即用的扩展? 让我们考虑 com.google.common.collect.Iterables.transform。现在,因为我不知道如何处理这个问题,
我想创建一个由 Guava 函数支持的只读 map 。我有一个提供值的函数,给定一个键。 Function f = new Function() { public Object apply(f
我最近将 Google Guava 作为库添加到我的 Eclipse 项目中(我从 http://code.google.com/p/guava-libraries/ 下载了“guava-16.0.j
我们最近从 Drools 5 升级到 Drools 6 并遇到了令人不安的冲突问题。 我们有kie-ci导入到项目中。 kie-ci引进 sisu-guava . sisu-guava改变了谷歌 Gu
尝试取消注册时,我在我的一个类(class)中收到以下错误。 java.lang.IllegalArgumentException: missing event handler for an anno
我的项目传递依赖于 Google Guava lib。突然(使用新版本的 Guava ?)应用程序在启动时崩溃java.lang.NoSuchMethodError: 'java.util.strea
我喜欢 Google Guava 并且经常使用它,但是我总是发现我在写一种方法。 public static T tryFind(Iterable iterable, Predicate pred
我使用的是普通的旧 Java 1.6,并且对这两个库都感兴趣。 阅读文档后,我不确定是否存在差异(如果有的话)。任何人都可以解释一下,或者指出一些相关信息吗?提前致谢! 最佳答案 RxJava 比 L
我用的是 Guava 17.0 private static final ConcurrentMap imageMap = new MapMaker().softValues().ma
我是一名优秀的程序员,十分优秀!