我可能用错了方法,但我有一个函数,我想用它来随时间发出多个值。但我不想让它开始发射,直到有东西订阅了那个对象。我是从RxSwift来组合的,所以我基本上是在尝试在RxSwift世界中复制Observable.create()。我找到的最接近的是Future a Future,但期货只会成功或失败(所以它们基本上就像RxSwift中的单个)。
我找不到任何使用FutureTask(Runnable runnable, V result)构造函数的特定示例。爪哇医生说
提交一个可运行的任务以供执行,并返回表示该任务的未来。未来的get方法将在成功完成后返回给定的结果。从这个角度来看,我的理解是,在任务完成时,futureTask.get()将返回传递给我们的给定的结果对象,该对象与"Runnable“作业无关。这是一种信号,表明“可运行的”任务已经完成。此外,结合E