仅当请求时，Guava转换listenableFuture

文章/答案/技术大牛

发布

1回答

guava

我有一个listenableFuture，我想链接另一个listenableFuture，它只有在原始ListenableFuture运行时才会运行，所以就像这样： listenableFuture, res -> res.doSomething但是，当我调用transform时</e

浏览 5提问于2018-02-12得票数 0

1回答

Android动态功能模块中的番石榴

android、guava、dynamic-feature-module

我的基本模块使用了几个Androidx库，这些库依赖于com.google.guava:listenablefuture:1.0。在为项目构建Relase时，我会得到以下错误 implementation "com.google.gua

浏览 8提问于2022-01-29得票数 0

1回答

期货转换的Fluent语法

java、java-8、guava、future

我正在使用将未来的调用链接在一起。特别是，我使用的是Futures.transform(...)和Futures.transformAsync(...)的组合，但是生成的代码并不是很容易读。有没有一种更“流利”的方式来表达同样的事情？

浏览 1提问于2017-05-17得票数 1

4回答

在迁移到New时复制jar (ListenableFuture.class)

android、google-places-api

(ListenableFuture)造成的。implementation ('com.google.android.libraries.places:places:1.0.0'){} 结果无错误。但是安装了apk，当我运行包含自动完成小部件的

浏览 0提问于2019-02-07得票数 12

回答已采纳

2回答

如何将java Future<V>转换为番石榴ListenableFuture<V>

java、concurrency、guava、futuretask

我需要找到一种从未来到ListenableFuture的转换方式。目前，我正在使用一个返回未来的服务，但我需要将侦听器连接到它。我不能更改服务接口，因为它不属于我。有什么简单的方法吗？

浏览 5提问于2015-05-11得票数 12

回答已采纳

3回答

带异步加载的LoadingCache

java、caching、guava

在芭乐中，当使用LoadingCache时，CacheLoader是同步调用的。

浏览 1提问于2013-07-04得票数 8

1回答

saveToCassandra与火花-卡桑德拉连接器抛出java.lang.ClassCastException

scala、apache-spark、cassandra、spark-cassandra-connector

当试图将数据保存到Cassandra(在Scala中)时，我得到以下异常： <dependency

浏览 2提问于2016-05-18得票数 7

1回答

Listenable回调严重延迟

java、multithreading、concurrency、guava、completable-future

我对我的Guava listenable未来的回调被延迟了。我正在编写一个应用程序，它本质上有一个线程池，一旦“长时间运行的任务”完成，我就会有一个成功的回调，如下所示： Futures.addCallback(listenableFuturehandler);

浏览 0提问于2020-08-28得票数 1

2回答

从流进行异步HTTP调用

corda

在Corda中，如何从流中发出异步HTTP请求？是否有API在等待对HTTP调用的响应时挂起流，或者提供回调的方法？

浏览 7提问于2017-12-07得票数 1

回答已采纳

2回答

RxJava的Observable.create与Observable.just(1).flatMap

java、reactive-programming、rx-java

我一直在做一些RxJava，我经常发现自己需要将一些现有的代码结果转换为可观察的代码结果。例如，让我们以以下内容为例：return result;return Observable.from(result); 问题是，当请求

浏览 7提问于2015-06-23得票数 3

回答已采纳

3回答

当future.isDone()在ListenableFuture中调用时，Java如何保证回调

java、asynchronous、guava

在通过接口时，它在文档中注意到注册要在给定执行器上运行的侦听器。侦听器将在Future的计算完成时运行，如果计算已经完成，则立即运行。在ListenableFuture的情况下，jvm支持这种开箱即用的东西吗？使用类似wait()/notify()的机制？FollowUp ：正如大家所指出的，调用方实际上保证侦听器能够运行，使用ListenableFuture的正常情况将是ListenableFuture future = Caller.call()，调用者和被调用者在不同的线程

浏览 0提问于2017-11-15得票数 1

回答已采纳

1回答

如果返回未来，是否有实现回调的用例？

java、multithreading、concurrency、asynchronous-programming

如果我有返回未来的函数，那么是否有任何理由也包括一个回调，在将来完成之前就简单地调用回调？对此是否有任何用例或实际应用程序？

浏览 0提问于2016-05-01得票数 5

回答已采纳

1回答

ListenableFuture链能处理内部ExecutionException吗？

java、asynchronous、java-8、guava、future

我得到了一个api (fnGrpc)，它执行gRPC调用，并返回一个解析为v (其实现是固定的和不可修改的)的值的ListenableFuture。我想提供一个助手函数(fnHelper)： package myHelper; return Futures.trans

浏览 0提问于2018-02-28得票数 2

回答已采纳

1回答

Guava ListenableFuture找不到源对象

java、guava

当使用Guava的ListenableFuture时，如何知道失败的任务。

浏览 2提问于2014-07-13得票数 1

2回答

Pyspark:如何读取谷歌存储桶中的.csv文件？

python、apache-spark、google-cloud-platform、pyspark

我有一些文件存储在google存储桶中。这些是我建议的设置。 master("local[*]").\ config("spark.serializer", KryoSerializer.getName).\ config("spark.jars", "/usr/local/.sdkman/candidates/spark/2.4.4/jars/gcs-co

浏览 4提问于2020-03-23得票数 3

4回答

根据键的一部分使Guava缓存无效

java、caching、guava

我使用Guava LoadingCache缓存外部存储的身份验证请求。当更改外部存储中username的密码时，我需要删除username的缓存记录，但问题是密码只作为散列存储，而不是原始值，所以我不能只构造新的Auth对象来使其无效，例如：如何仅使用username值使缓存记录无效？

浏览 1提问于2016-10-01得票数 1

3回答

通过拆分并运行将ListenableFuture<Iterable<A>>转换为Iterable<ListenableFuture<B>>

java、asynchronous、concurrency、guava、future

我正在寻找最好的方法来转换成一个单独的ListenableFutures序列的ListenableFuture<Iterable<A>>。这就是我正在寻找的方法签名： final ListenableFuture<Iterable<Iterable<ListenableFuture<B>>&

浏览 0提问于2013-02-21得票数 7

回答已采纳

1回答

使用Spring缓存抽象的异步缓存更新

java、spring、caching、asynchronous、spring-cache

然后，当它们被查询时，返回缓存的值，并启动异步更新操作来刷新条目。我也会是否可以使用Spring的缓存抽象进行这种异步缓存刷新？编辑以澄清:使用Guava的CacheBuilder，我可以使用refreshAfterWrite()来获得我想要的行为。{ // no checked exception return get

浏览 0提问于2015-06-03得票数 10

3回答

J2EE环境.多线程并行从不同服务中获取数据

java、multithreading、performance、jakarta-ee、design-patterns

是否有更好的选择(设计/性能/内存优化)来替代我在下面使用的内容：问题陈述:在J2EE环境中，当请求出现时，我的控制器需要从三个不同的服务(例如)中获取数据。对于每个请求控制器，创建一个新的“ForkJoinPool”实例--而不是在每个请求上创建它。

浏览 2提问于2015-01-09得票数 2

回答已采纳

2回答

Firebase Android:在模块中发现重复的Protobuf类

android、firebase、gradle

//implementation.exclude module:'protolite-well-known-types'| +--- com.squareup.okhttp:okhttp:2.7.5| +--- org.codehaus.mojo:

浏览 1提问于2020-08-10得票数 0

点击加载更多