我努力,但没有发现任何文章或博客清楚地比较ListenableFuture
和CompletableFuture
,并提供了一个很好的分析.
因此,如果有人能够解释或指向我这样的博客或文章,那对我来说真的很好.
我想知道我们需要“序列化”可观察序列的情况,这是必要的。我的意思是“ onNext”方法将被并发调用而不是一个接一个地调用的情况。
在本地以较少负载进行测试时,它工作正常。
private static class CoordinateComparator implements Comparator<Coordinate> {
@Override
public int compare(Coordinate o1, Coordinate o2) {
return o1.x <= o2.x ? -1 : 1;
}
}
Run Code Online (Sandbox Code Playgroud)
这里 x 是原始的,它在运行测试时给出运行时错误。在沉重的负荷下,它正在破裂。
然后我将比较器更改为:-
private static class CoordinateComparator implements Comparator<Coordinate> {
@Override
public int compare(Coordinate o1, Coordinate o2) {
return o1.x.compareTo(o2.x);
}
}
Run Code Online (Sandbox Code Playgroud)
在这种情况下,x 是整数。然后它开始正常工作。为什么会发生这种情况的任何想法或想法。我将这个比较器传递给 Collections.sort(array, comp)