Tag: 并行

并行处理文件中的行（Scala）？

我知道斯卡拉平行集合。 他们很方便！ 但是，我想遍历一个太大的文件的行并行内存。 例如，我可以创build线程并设置对扫描器的locking，但如果我可以运行如下代码将会很好： Source.fromFile(path).getLines.par foreach { line => 不幸的是， error: value par is not a member of Iterator[String] 在这里完成一些平行的最简单的方法是什么？ 就目前而言，我会用一些线条来解读并行处理。

你如何查询一个pthread，看看它是否仍在运行？

在我的析构函数中，我想干净地破坏一个线程。 我的目标是等待一个线程完成执行，然后破坏线程。 我发现查询pthread的唯一情况是pthread_attr_setdetachstate，但是这只能告诉你，如果你的线程是： PTHREAD_CREATE_DETACHED PTHREAD_CREATE_JOINABLE 这两者与线程是否仍在运行无关。 你如何查询一个pthread，看看它是否仍在运行？

R中doMC和doParallel的区别

R中关于foreach函数的doParallel和doMC什么区别？ doParallel支持windows，类似unix，而doMC只支持unix。 换句话说，为什么doParallel不能直接取代doMC ？ 谢谢。 更新： doParallelbuild立在parallel基础上，这本质上是multicore和snow的合并，并自动为您的系统使用适当的工具。 因此，我们可以使用doParallel来支持多系统。 换句话说，我们可以用doParallel来代替doMC 。 ref： http : //michaeljkoontz.weebly.com/uploads/1/9/9/4/19940979/parallel.pdf 顺便说一句， registerDoParallel(ncores=3)和 cl <- makeCluster(3) registerDoParallel(cl) 看来registerDoParallel(ncores=3)可以自动停止集群，而第二个不会自动停止，需要stopCluster(cl) 。 ref： http : //cran.r-project.org/web/packages/doParallel/vignettes/gettingstartedParallel.pdf