这个scala并行数组代码线程安全吗？

发布时间：2020-12-16 18:44:40 所属栏目：安全来源：网络整理

导读：我想将并行数组用于任务,在开始编码之前,我有兴趣知道这个小snipept是否是线程安全的： import collection.mutable._var listBuffer = ListBuffer[String]("one","two","three","four","five","six","seven","eight","nine")var jSyncList = java.util.Colle

我想将并行数组用于任务,在开始编码之前,我有兴趣知道这个小snipept是否是线程安全的：

import collection.mutable._

var listBuffer = ListBuffer[String]("one","two","three","four","five","six","seven","eight","nine")
var jSyncList  = java.util.Collections.synchronizedList(new java.util.ArrayList[String]())
listBuffer.par.foreach { e =>
    println("processed :"+e)
    // using sleep here to simulate a random delay
    Thread.sleep((scala.math.random * 1000).toLong)
    jSyncList.add(e)
}
jSyncList.toArray.foreach(println)

是否有更好的方法来处理并行集合的东西,并在其他地方积累结果？

解决方法

您发布的代码非常安全;我不确定这个前提：为什么你需要在非平行的集合中累积并行集合的结果？并行集合的一个重点是它们看起来像其他集合.

我认为并行集合也将提供一种seq方法来切换到顺序方法.所以你应该用这个！

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!