CompletableFuture、Future和RxJava的可观测值之间的差异

期货

Java 5（2004）引入了期货。它们基本上是尚未完成的操作结果的占位符。一旦操作完成，未来将包含该结果。例如，操作可以是提交给ExecutorService的可运行或可调用实例。操作的提交者可以使用Future对象检查操作是否为isDone（），或者使用blocking get（）方法等待操作完成

例如：

/**
*休眠一秒钟后返回1的任务
**/
公共静态类MyCallable实现了Callable&lt；整数&gt；{
@凌驾
公共整数调用（）引发异常{
睡眠（1000）；
返回1；
}
}
公共静态void main（字符串[]args）引发异常{
ExecutorService exec=Executors.newSingleThreadExecutor（）；
Future&lt；Integer&gt；f=exec.submit（new MyCallable（））；
System.out.println（f.isDone（））；//False
System.out.println（f.get（））；//等待任务完成，然后打印1
}

可完成期货

Java 8（2014）引入了CompletableFutures。事实上，它们是常规期货的演变，灵感来自谷歌的Listenable Futures，它是Guava图书馆的一部分。它们是未来，也允许您将任务串成一个链。您可以使用它们来告诉某个工作线程“执行某个任务X，完成后，使用X的结果执行另一个任务”。使用CompletableFutures，您可以对操作的结果执行某些操作，而无需实际阻止线程等待结果。下面是一个简单的例子：

/**
*一个供应商睡了一秒钟，然后返回一个
**/
公共静态类MySupplier实现供应商&lt；整数&gt；{
@凌驾
公共整数get（）{
试一试{
睡眠（1000）；
}捕捉（中断异常e）{
//无所事事
}
返回1；
}
}
/**
*向给定整数加一的（纯）函数
**/
公共静态类PlusOne实现函数&lt；整数，整数&gt；{
@凌驾
公共整数应用（整数x）{
返回x+1；
}
}
公共静态void main（字符串[]args）引发异常{
ExecutorService exec=Executors.newSingleThreadExecutor（）；
CompletableFuture&lt；Integer&gt；f=CompletableFuture.supplyAsync（新的MySupplier（），exec）；
System.out.println（f.isDone（））；//False
CompletableFuture&lt；Integer&gt；f2=f.thenApply（新PlusOne（））；
System.out.println（f2.get（））；//等待“计算”完成，然后打印2
}

RxJava

RxJava是Netflix创建的整个反应式编程库。乍一看，它似乎类似于Java8的流。是的，只是它的威力要大得多

与Futures类似，可以使用RxJava将一组同步或异步操作串在一起，以创建一个处理管道。与单一用途的期货不同，RxJava处理零或多个项目的流。包括无限数量的项目的永无止境的流。它也更加灵活和强大，这要归功于一组难以置信的丰富运营商