ClassCastException:接口 akka.actor.Scheduler 不可从 class akka.actor.LightArrayRevolverScheduler 分配

ClassCastException: interface akka.actor.Scheduler is not assignable from class akka.actor.LightArrayRevolverScheduler

我正在尝试 运行 我已经 运行 在各种条件下成功 运行 几个月了。我正在使用 akka-actor_2.11 2.3.4 和来自 Java 应用程序的 scala-library 2.11.7 运行ning Java 7 . 就像我说的,同样的代码已经工作了几个月。在最近的情况下,我得到以下信息:

java.lang.ClassCastException: interface akka.actor.Scheduler is not assignable from class akka.actor.LightArrayRevolverScheduler
at akka.actor.ReflectiveDynamicAccess$$anonfun$getClassFor.apply(DynamicAccess.scala:69)
at akka.actor.ReflectiveDynamicAccess$$anonfun$getClassFor.apply(DynamicAccess.scala:66)
at scala.util.Try$.apply(Try.scala:192)
at akka.actor.ReflectiveDynamicAccess.getClassFor(DynamicAccess.scala:66)
at akka.actor.ReflectiveDynamicAccess.createInstanceFor(DynamicAccess.scala:84)
at akka.actor.ActorSystemImpl.createScheduler(ActorSystem.scala:677)
at akka.actor.ActorSystemImpl.<init>(ActorSystem.scala:576)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:142)
at akka.actor.ActorSystem$.apply(ActorSystem.scala:109)
at akka.actor.ActorSystem$.create(ActorSystem.scala:57)
at akka.actor.ActorSystem.create(ActorSystem.scala)

有问题的电话是: system= ActorSystem.create("MyActorSystem");

此调用发生在 class 的构造函数中,它是通过反射 ala getConstructor(...).newInstance(...) 动态加载的。

当我写的分布式计算环境的用户尝试执行一个动态实例化作业的作业时,问题就出现了,该作业动态实例化一个作业(2 级反射实例化)。基本上,类似于这个伪调用列表:

reflectivelyCreate(job)
job.reflectivelyCreate(job2)
job2.instantiateActorSystem()
<fail>

如果我运行完全相同的代码如下:

reflectivelyCreate(job2)
job2.instantiateActorSystem()
<success>

一切正常。

我的问题是在 Java 的幕后是否发生了一些与状态 class 加载程序相关的魔术,以至于 Akka 对其状态的假设是不正确的。我发现的类似问题 (Akka ActorSystem creation issue) 似乎与线程/scala repl 调用有关,但我的代码是单线程的,并且在上述成功和失败情况下的调用方式相同。据我所知,有问题的调用仅在调用堆栈的深度不同时才会发生。

非常感谢 akka 专家的任何意见!

如果其他人无意中发现了这个;在我的案例中,问题是我在可能也使用 Akka 的同一进程中使用了 Scala 解释器。其他多类加载器场景可能会出现相同的问题。这是针对我的案例的修复:

  • 使用 private static ClassLoader ourClassLoader = CmdLineMain.class.getClassLoader();
  • 在程序初始化时将我喜欢的类加载器(加载 akka 库的类加载器)保存在静态字段中
  • 使用 scala 解释器(它显然用它喜欢的类加载器替换了类加载器)后,调用 Thread.currentThread().setContextClassLoader(ourClassLoader);

我的程序是单线程的,但肯定有其他方法可以解决问题,例如每个线程维护自己的加载程序。那超出了这个范围 post ;)