在 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(使用前将#替换为@)