1回答
我正在使用Spring4.2.3API()来调用一些需要几秒钟的AsyncRestTemplate.exchange，我期望listenableFuture.get(1，TimeUnit.SECONDS)会阻塞1秒，然后抛出TimeOutException。取而代之的是，listenableFuture.get()将在整个api调用期间(超过1秒)阻塞。AsyncRestTemplate restTemplate = new AsyncRestTemplate();
Listenable
浏览 12提问于2017-02-16得票数 6
回答已采纳
将来的对象来自另一个库Firebase Cloud Firestore- Admin SDK for Java，并提供阻塞调用get()来检索所述将来的结果。: DEFAULT_PREFIX} 我考虑过的解决方案 我考虑的第一件事是在kotlinx.coroutine中寻找连接未来的扩展。我在一个编程社区上询问了我的问题，那里有人推荐我使用Deferred- val deferred = CompletableDeferred<DocumentSna
浏览 16提问于2020-08-12得票数 7
如果我在使用调用外部系统时得到一个ListenableFuture<X>，并且我立即调用了get() -当前线程是否不会等到异步线程准备好响应？如果这是真的，使用AsyncHttpClient的好处是什么？AsyncHttpClient httpClient = new AsyncHttpClient();
ListenableFuture<Response> futureResponse = httpClient.execute
浏览 15提问于2016-09-02得票数 2
我使用的是RxJava 2.0.0-RC4。我试过这个：
Flowable<ListenableFuture<List<Integer>>> futures = ...Flowable<Inte
浏览 4提问于2016-10-25得票数 1
回答已采纳
2回答
); boolean deleteEmployee(Employee employee);我在互联网上的其他答案和文章中也看到了类似的例子也就是说，在find...()调用期间阻塞可能不是期望的行为。我认为用诸如EmployeeDAO.Listener之类的方法创建监听器接口( void EmployeeFound(Employee employee) )是有意义的，但我很惊讶以前在DAO示例中没有看到过这种情况
浏览 7提问于2016-03-04得票数 2
回答已采纳
(如果IO不成功)所以在最坏的情况下，所有的跑步者都会坐在that循环中？
浏览 1提问于2014-11-18得票数 0
回答已采纳
在通过接口时，它在文档中注意到
注册要在给定执行器上运行的侦听器。侦听器将在Future的计算完成时运行，如果计算已经完成，则立即运行。既然Future.get()是一个阻塞调用，那么如何保证实现某些未来呢？他们在玩这个吗？我了解到，有了像匕首生产者这样的框架，就很容易理解了(一旦任务完成，写到某个东西上，监视线程就会被通知)。在ListenableFuture的情况下，jvm支持这种开箱即用的东西吗？
使用类似wait()/no
浏览 0提问于2017-11-15得票数 1
回答已采纳
我有一个这样的代码片段 public ListenableFuture<ProductCatalog> someAsync(List<someItem> someItemList) throws Exceptionpublic ListenableFuture<ProductCatalog> someAsync(List<someItem> someItemList) throws Exception {ListenableFuture<ProductCatalog> Lp =
浏览 22提问于2021-08-26得票数 0
回答已采纳
我使用WSO2 ESB4.9.0进行使用阻塞调用的后端服务调用。由于jms事务，我不得不使用阻塞调用。有时ESB和后端服务之间的网络速度很慢，所以我想在连接上使用超时，但在阻塞时，端点上的调用超时不起作用。使用非阻塞调用时，超时工作得很好。谢谢你的建议。
浏览 1提问于2016-06-28得票数 2
我有一个阻塞测试(第一个代码块)。我有几个元素都在一起工作。我有一个阻塞队列，我把事件放在上面，然后我有一个消费者把它们取下来并发送到Amazon。我很确定我的测试被阻塞了，因为队列阻塞了我的使用者，尽管我认为它是在一个单独的线程上运行。"TestStream", mockKinesis, testQ);
Event event = new Event("TestMessage", "TestPartition&
浏览 0提问于2016-11-10得票数 0
回答已采纳
我正在尝试测试spring kafka(2.2.5.RELEASE)，当生产者使用kafkatemplate发送消息时，我想知道该消息是否成功发送。基于此，我想更新该消息id的数据库记录。以下是检查成功或失败的示例代码 ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("test_topic"
浏览 520提问于2020-03-17得票数 1
回答已采纳
我得到了一个api (fnGrpc)，它执行gRPC调用，并返回一个解析为v (其实现是固定的和不可修改的)的值的ListenableFuture。我想提供一个助手函数(fnHelper)：
package myHelper;
return Futures.transform如何实现(2)当fnHelp
浏览 0提问于2018-02-28得票数 2
回答已采纳
<Result> listenableFuture = connection.submitItem(item); } catch (RejectedExecutionExceptionI will not propagate up because I own this thread");
浏览 5提问于2015-12-21得票数 1
在向ListenableFuture提交任务时使用ExecutorService来处理结果，而不是简单地调用一个处理结果的函数，而不是用普通的java方式进行处理，有什么好处吗？running process to get scanResult });或使用番石榴ListenableFuture来防止手动调用get()。
浏览 3提问于2016-10-16得票数 0
我在我的项目中使用了番石榴的ListeningExecutorService，对异常处理感到困惑。我使用了一个线程池，向它提交了一个任务，并为listenableFuture设置了一个超时，并向它添加了一个回调。threadPool = MoreExecutors.listeningDecorator(Executors.newCachedThreadPool());
浏览 0提问于2017-12-21得票数 1
我有我的任务和后遗症：ListenableFuture<T> listenableFallbackTask = executorService.submit(fallBackTaskCallable); @Override
浏览 1提问于2016-04-12得票数 2
回答已采纳
每当我调用KafkaTemplate的send方法，返回一个ListenableFuture，它就会阻塞。查看KafkaProducer的源代码，实际上似乎是这样的--我发现了对名为"waitOnMetadata“的方法的调用。
我漏掉了什么明显的东西吗？当我把唱片寄给卡夫卡时，我该如何避免阻止呢？
浏览 2提问于2017-03-20得票数 1
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
对象存储
腾讯云开发者
