如果我在使用调用外部系统时得到一个ListenableFuture<X>，并且我立即调用了get() -当前线程是否不会等到异步线程准备好响应？AsyncHttpClient httpClient = new AsyncHttpClient();
ListenableFuture<Response> futureResponse = httpClient.executeResponse response = futureResponse.get();
浏览 15提问于2016-09-02得票数 2
ListenableFuture如何检查结果是否准备就绪，以便能够立即执行、或尽可能快地执行已注册的侦听器？ListenableFuture是否忙于通过调用isDone()来等待(我认为这是一个愚蠢的解决方案)？或者，它是否有内部任务可以定期调用带有一些优化超时值的get(long timeout, TimeUnit unit)？如果它是周期性地唤醒来调用get(long timeout, TimeUnit unit)，那么是否有一个参数可以让用户对此行为进行调优，因为
浏览 0提问于2021-04-08得票数 0
回答已采纳
在我的应用程序中，我收到了一个Flowable<ListenableFuture<List<Integer>>。(ListenableFuture来自番石榴。)我怎样才能把这个可流动的流压成一个Flowable<Integer>Flowable<ListenableFuture<List<Integer>>> futures = ...Flowable<Integer> ints = futures.flatMap(future -&g
浏览 4提问于2016-10-25得票数 1
回答已采纳
1回答
我能想到的唯一优势是保证在未来的任务尚未完成之前执行一些操作，并且保证该操作发生在未来调用的同一线程中。
对此是否有任何用例或实际应用程序？
浏览 0提问于2016-05-01得票数 5
回答已采纳
我有一个listenableFuture，我想链接另一个listenableFuture，它只有在原始ListenableFuture运行时才会运行，所以就像这样： listenableFuture, );
我希望doS
浏览 5提问于2018-02-12得票数 0
我和WorkManager阿尔法05合作。它有两种方法：
方法1工作正常。 WorkManager.getInstance().getStatusById(taskID)
.observe(LifecycleOwner, Observ
浏览 2提问于2018-07-27得票数 2
回答已采纳
以一个或多个实现异步计算的FutureTask (侦听多播数据包传输不同类型的统计信息)为例，我们将其命名为MulticastStatisticsProvider，
使用另一个依赖于第一个任务的计算来执行额外的计算, timeUnit)在调用MulticastStatisticsProvider.get(timeout, timeUnit)时将超时传播到其内部Callable，而无法找到实现该超时的方法。public FormulaComputing getFormulaComputing() { //从另一个服务中检索已经/
浏览 3提问于2014-01-21得票数 1
回答已采纳
在通过接口时，它在文档中注意到
注册要在给定执行器上运行的侦听器。侦听器将在Future的计算完成时运行，如果计算已经完成，则立即运行。既然Future.get()是一个阻塞调用，那么如何保证实现某些未来呢？他们在玩这个吗？我了解到，有了像匕首生产者这样的框架，就很容易理解了(一旦任务完成，写到某个东西上，监视线程就会被通知)。在ListenableFuture的情况下，jvm支持这种开箱即用的东西吗？
使用类似wait()/notify()的机制？FollowUp ：正如大家所指出
浏览 0提问于2017-11-15得票数 1
回答已采纳
请求由返回ListenableFuture的客户端执行。现在，我想保留一个期货池，例如，最大限度地并发执行N ListenableFuture。我看到的问题是，由于第三方库的原因，我无法控制执行ListenableFuture的ExecutorService。否则，我将只创建一个FixedSizePool并创建我自己的Callables。4)一种非ListenableFuture-related方法是直接.get()结果，并通过创建一个简单的Threa
浏览 2提问于2014-08-14得票数 0
1回答
我想实现一个异步操作：//…lf.addListener(myRunnableCallback, myExecutor);
问:假设异常不是在executeAsync()调用中立即抛出的，我如何区分成功的执行和失败的执行？我能想到的唯一方法是，当调用完成回调时，lf.get()会在失败时抛出一个异常。
浏览 5提问于2014-02-11得票数 0
回答已采纳
我有两个ListenableFutures，这是在其他线程上完成。每个未来都属于不同的类型，我希望在它们都完成时使用它们的结果。
浏览 0提问于2012-12-07得票数 12
回答已采纳
我需要在工作完成时从WorkManager (android.arch.work:work-runtime-ktx:1.0.0-alpha11).进行回调然而，我添加的侦听器在安排好工作后立即被调用。run() }
listener()
浏览 4提问于2018-11-13得票数 6
在下面的代码中，我将2 FutureCallbacks添加到单个ListenableFuture中。
我的问题是:2 FutureCallbacks是按照我添加的顺序执行，还是分别异步运行？JavaDoc说，寄存器将在未来计算完成时运行成功和失败回调，如果计算已经完成，则立即运行。没有保证执行回调的顺序，但任何通过此方法添加的回调都保证在计算完成后被调用。ListeningExecutorService service = MoreExecutors.listeningDecorator(Executor
浏览 2提问于2014-10-15得票数 0
回答已采纳
1回答
... params) { mCustomerTable.pull(mPullQuery_Customer).get(); //Few mor
浏览 1提问于2015-11-15得票数 1
大约10分钟后，addOnFailureListener就会收到错误消息。
只有当应用程序最小化，手机屏幕被关闭时，才会出现这个问题。否则这一切都是可行的。
浏览 1提问于2019-11-19得票数 0
回答已采纳
我有我的任务和后遗症：ListenableFuture<T> listenableFallbackTask = executorService.submit(fallBackTaskCallable);ListenableFuture<T> failTo
浏览 1提问于2016-04-12得票数 2
回答已采纳
cuboidResp.addListener(() -> { System.out.println(cuboidResp.getsphereResp.addListener(() -> { System.out.println(sphereResp.get基本上，所期望的结果只是在计算完成后打印出来，这就是为什么在System.out.println部件中调用一个runnable。虽然程序<
浏览 0提问于2021-03-29得票数 1
3回答
我创建了一个ListenableFuture，如下所示：ListenableFuture<X> future2 = ..., executor);public void onSuccess(Object result) {}
在回调中执行.ge
浏览 0提问于2020-09-04得票数 1
据我所知，Guava的创建了一个，它将在execute方法调用返回之前执行runnable。
需要直接执行者的使用程序是什么？调用方不能直接调用runnable.run()，而不能通过创建一个执行器并将runnable提交给这个执行器来代替额外的间接级别吗？也许我错过了它存在的真正目的。我想知道在什么情况下这是有用的。
浏览 8提问于2017-02-01得票数 1
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号