【发布时间】：2014-06-18 22:46:27
【问题描述】：
所以我只是在学习新的 Java 8，特别是 lambda 和日期和时间 API。我正在将它与scala进行比较。我的基本想法是找到命令式、流和并行流之间的执行时间差异。所以我决定创建一个图书馆应用程序并执行一些操作，如搜索、过滤、排序等。我创建了一个图书馆类，其中包含一个名为书籍的列表字段，并用 1000 本书填充它。然后为搜索创建了一个功能界面，并对所有三种样式进行了一些操作。一切都很好。我的代码是：
// Functional Interface
interface Search<T> {
public void search(T t);
}
// Library class
final Library library = new Library();
// This just creates some random book objects.
final List<Book> books = collectBooks();
final Search<List<Book>> parallelSearch = (bks) -> library.findAndPrintBooksParallel(bks);
// Parallel Operations
private void findAndPrintBooksParallel(List<Book> books) {
books.parallelStream()
.filter(b -> b.getAuthor().equals("J.K. Rowling"))
.sorted((x,y) -> x.getAuthor().compareTo(y.getAuthor()))
.map(Book::getIsbn)
.forEach(Library::waitAndPrintRecord);
}
现在我尝试在 scala 中重新创建相同的程序，看看执行是否更快？令人惊讶的是，scala 不允许我进行并行排序（或者我在这里可能是无知的）。我的 scala 库是
// Again some random book objects as a list
val books = collectBooks
// Parallel operation
books.par filter(_.author == "J.K. Rowling") map (_.isdn) foreach waitAndPrint
这里books.par 给出了 ParSeq。这没有排序方法。有什么方法可以在 scala 中创建与我的书单的并行排序。所以我可以写这样的东西：
books.par filter(_.author == "J.K. Rowling") sortWith (_.author < _.author) map (_.isdn) foreach waitAndPrint
非常感谢您的帮助。谢谢。
【问题讨论】：
-
sorted由scala.collection.SeqLikeonly 提供，它只是委托给java.util.Arrays.sort(T[] a, Comparator<? super T> c): GitHub.Com/Scala/Scala/blob/master/src/library/scala/collection/… 所以，排序本身永远不会并行，只有与 Java 数组之间的转换可能。 -
是的。我读过那个。我想知道我们是否可以向 ParSeq 添加排序方法。
-
你的问题的意图有点不清楚。您能否尝试以问题的形式重新表述您的内容，以便人们可以为您指出正确的方向？您是在问如何在 Scala 中进行并行排序？
-
也许您可以通过删除有关功能界面的部分以及所有这些来使问题更清楚，并只关注我认为是您的核心问题，即 - 有没有办法写一个简洁的，Scala 中面向序列的并行排序函数（类似于您在最后一个代码块中提供的语法）？恐怕您提供的有关 Java 8 的背景信息会使您的问题的意图有点不清楚。
标签： java scala lambda parallel-processing java-stream