Scala 反射中的线程安全与类型匹配

2023-12-07

在 scala 2.11.12、JDK 1.8.0_131 中工作,我已经能够使用以下代码复制在 Apache Spark 中观察到的线程安全错误,其中我反复检查多个线程是否Option[Int]可以通过匹配<:< to Option[_]:

package stuff

import java.util.concurrent.{Executors, Future}

import scala.collection.mutable.ListBuffer

object Main {
  val universe: scala.reflect.runtime.universe.type = scala.reflect.runtime.universe
  import universe._

  def mirror: universe.Mirror = {
    universe.runtimeMirror(Thread.currentThread().getContextClassLoader)
  }

  def localTypeOf[T: TypeTag]: `Type` = {
    val tag = implicitly[TypeTag[T]]
    tag.in(mirror).tpe.dealias
  }

  def matcher[T: TypeTag]: Boolean = {
    val typ = localTypeOf[T]
    typ.dealias match {
      case t if t <:< localTypeOf[Option[_]] =>
        true
      case _ =>
        false
    }
  }

  def main(args: Array[String]): Unit =  {
    val executor = Executors.newFixedThreadPool(5)

    try {
      val futures = new ListBuffer[Future[_]]()

      for (i <- 1 to 10) {
        futures += executor.submit(new Runnable {
          override def run(): Unit = {
            if (Main.matcher[Option[Int]]) {
              println("ALL OK")
            } else {
              throw new Exception("THIS SHOULD BE IMPOSSIBLE!!!!!!")
            }
          }
        })
      }

      futures.foreach(_.get())
    } finally {
      executor.shutdown()
    }
  }
}

此代码应始终打印“ALL OK”,但有时(~5% 的机会)它实际上会抛出“THIS SHOULD BE IMPOSSIBLE”错误,并具有以下堆栈跟踪:

Exception in thread "main" java.util.concurrent.ExecutionException: java.lang.Exception: THIS SHOULD BE IMPOSSIBLE!!!!!!
at java.util.concurrent.FutureTask.report(FutureTask.java:122)
at java.util.concurrent.FutureTask.get(FutureTask.java:192)
at stuff.Main$$anonfun$main$2.apply(Main.scala:81)
at stuff.Main$$anonfun$main$2.apply(Main.scala:81)
at scala.collection.immutable.List.foreach(List.scala:392)
at scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:35)
at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:45)
at stuff.Main$.main(Main.scala:81)
at stuff.Main.main(Main.scala)
Caused by: java.lang.Exception: THIS SHOULD BE IMPOSSIBLE!!!!!!
at stuff.Main$$anonfun$main$1$$anon$1.run(Main.scala:75)

at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)ALL OK

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
  • Why?
  • 我可以在程序中更改一些内容来修复此行为吗?
  • 如果这是 scala 的问题,它会在未来的版本中修复吗?

  • Why?事实证明这是 scala 反射本身的一个已知线程安全错误https://github.com/scala/bug/issues/10766
  • 我可以在程序中更改一些内容来修复此行为吗?尝试了几件事后,它可以包装每一个<:<在同步块中调用。仍然有兴趣知道是否有人有更优雅的方法来做到这一点。
  • 如果这是 scala 的问题,它会在未来的版本中修复吗?不,它存在于所有当前版本的 scala 中(通过2.13.0-M5)(参见上面的 scala 问题)。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Scala 反射中的线程安全与类型匹配 的相关文章

随机推荐