Scala死锁与并行集合

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

导读：为什么以下代码会造成死锁： object Test extends Application{ def printProgress(i:Int) = { println("Processed " + i) } println("A") (1 to 1000).par.foreach{ i = printProgress(i) } println("B")} (即打印A,但不打印B或任何已处理的……行.) 但是,

为什么以下代码会造成死锁：

object Test extends Application
{
  def printProgress(i:Int) =
  {
    println("Processed " + i)
  }

  println("A")
  (1 to 1000).par.foreach{ i =>  
    printProgress(i)
  }   
  println("B")
}

(即打印A,但不打印B或任何已处理的……行.)

但是,以下代码不会导致死锁：

object Test extends Application
{
  println("A")
  (1 to 1000).par.foreach{ i =>  
    println("Processed " + i)
  }   
  println("B")
}

(即一切都被打印出来.)

我正在运行Scala版本2.9.1.final.

解决方法

可能是因为你扩展了应用程序,而我无法分辨你的两个例子之间的区别.

使用Application,代码在类main初始化的方法main之外执行.此时JVM受到严重限制,尤其与多线程有关.不赞成应用程序有利于App,它有一些魔法(trait DelayedInit),导致代码在main中执行.所以对象测试扩展App应该修复它.

（编辑：李大同）

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