从客户机实现的角度来看，我能比较一下Java Callable和Angular Observable（RxJS）吗

Question

从http://winterbe.com/posts/2015/04/07/java8-concurrency-tutorial-thread-executor-examples中，我们看到了这个简单的示例：

ExecutorService executor = Executors.newFixedThreadPool(1);
Future<Integer> future = executor.submit(task);

System.out.println("future done? " + future.isDone()); // prints future done? false

Integer result = future.get();

System.out.println("future done? " + future.isDone()); // prints future done? true
System.out.print("result: " + result); //result: 123

那么，添加我可以控制何时调用Future.get（）的想法在实践中与Observable的想法是完全相同的。我的意思是，例如，我可以使用callable调用rest服务，然后在一段时间后获得结果，而不阻塞我的代码，并控制我将接受这个懒惰的Beaviour的最大时间（秒）。

我仔细阅读了Java8流和RxJava可观测数据之间的区别，很明显，Java流与Angular可观测数据有很大不同，但我想知道我是否正确理解了Java callable和ExecutorService的概念。

Answer 1

我不是一个Java的人，但对我来说callables似乎是JavaScript中promise的对应物。

在非常简短和粗略的比较中，主要的区别是：

• promises和callables是基于拉式的，而observable是基于推式的，
• promises和callables只发出一次数据，然后完成，Observables多次发出

那么，添加我可以控制何时调用Future.get（）的想法在实践中与Observable的想法是完全相同的。

不，作为使用者，控制何时调用get与控制何时调用then上的promise是一样的。您无法控制可观察对象何时作为使用者发出。

但是ofc和RxJS在很多其他方面有所不同，但这些是主要原因。