当前位置: 首页 > 知识库问答 >
问题:

Spring AMQP相关数据getFuture是否无限期等待而不超时?

戚甫
2023-03-14

在发布服务器确认的上下文中,当等待相关数据的未来(SettableListenableFuture#get())时,它是无限期等待还是在水下配置超时?

共有1个答案

宇文温文
2023-03-14

它确实无限期地等待。只是没有任何意见,所有内容都直接委托给org.springframework.util.concurrent.SettableListenableFuture实现中的java.util.concurrent.FutureWG内部。

不知道为什么会出现这个问题,但在正常情况下,当经纪人出现时,将在合理的有限时间内进行确认。如果代理不可用,那么在到达CorrelationData之前,您将失败很多。在代码中设置getFuture()

 类似资料:
  • 它是100%保证的线程,首先得到wait_for_completion_timeout会唤醒第一次调用完成?也许我错了,但是我看了下面的场景:线程A调用wait_for_completion_timeout并进入睡眠。当完成被调用时,它醒来并完成执行在函数do_wait_for_common。现在假设另一个线程B调用wait_for_completion_timeout. x- 然后继续睡觉。所以

  • 有没有更好的写法呢?由于某种原因,我真的需要这个循环吗?(似乎与有关)

  • 问题内容: 我有一个Python程序,该程序通过 PySerial 模块从串行端口读取数据。我需要牢记的两个条件是:我不知道会有多少数据到达,并且我也不知道何时需要数据。 基于此,我提出了以下代码段: 因此,此代码将永远循环以从串行端口获取数据。我们最多可以存储500个字符,然后通过设置一个标志来警告主循环。如果没有数据,我们将回到睡眠状态并等待。 该代码正在运行,但是我不喜欢5s超时。我需要它是

  • 问题内容: 我有两个数组,可以这样说: //这些数组应该相等 我想以“最干净”的方式检查他们的平等。 我尝试使用,但得到的答案是错误的。我猜想这种方法关心元素的顺序,我不想这样。 您能告诉我如何以一种不错的方式做到这一点吗? 问题答案: Arrays.sort(s1); Arrays.sort(s2); Arrays.equals(s1,s2); 如果您不想修改原始数组 Arrays.sort()

  • 我实际上有三个问题: Selenium WebDriver如何实现此 因为我们不能给无限睡眠的线程一个负值。 有没有更好的方法来实现无限等待? 我们在SeleniumWebDriver文档中看到了这一点

  • 我在ExecutorService中有一些可运行的线程,希望在以下时间后加入线程: 因为它在Runnable中调用自己,所以我不能关闭,因为它可能会阻止自己创建新任务。 如何在不关闭的情况下等待所有线程完成?有没有办法返回一个未来,这样我就可以使用未来::get()。