ClassCastException:接口akka.actor.Scheduler不能从类akka.actor.LightArrayRevolverScheduler分配

Question

我试图在几个月的条件下运行我已成功运行的各种条件.我正在使用akka-actor_2.11 2.3.4与运行Java 7的Java应用程序中的scala-library 2.11.7.就像我说的,相同的代码已经工作了几个月.在最近的情况下,我得到以下内容:

java.lang.ClassCastException: interface akka.actor.Scheduler is not assignable from class akka.actor.LightArrayRevolverScheduler
at akka.actor.ReflectiveDynamicAccess$$anonfun$getClassFor$1.apply(DynamicAccess.scala:69)
at akka.actor.ReflectiveDynamicAccess$$anonfun$getClassFor$1.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");

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

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

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

如果我以下列方式运行完全相同的代码:

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

一切正常.

我的问题是,是否在Java中幕后发生了一些有状态的类加载器相关魔法,以至于Akka对其状态的假设是不正确的.我发现的类似问题(Akka ActorSystem创建问题)似乎与线程/ scala repl调用有关,但我的代码是单线程的,并且在上面的成功和失败情况下都以相同的方式调用.到目前为止,只有在调用堆栈深度不同的情况下才会发生有问题的调用.

我很感激来自akka大师的任何意见!

Answer 1

如果其他人偶然发现了这个；我的例子中的问题是我在同一进程中使用了 scala 解释器，该进程也可能使用 Akka。其他多类加载器场景可能会出现相同的问题。这是我的案例的修复方法：

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

我的程序是单线程的，但肯定还有其他方法可以解决该问题，例如每个线程维护自己的加载程序。这超出了本文的范围；）