Tag: actor

如何在Java应用程序中使用TypedActor？: 我尝试按照Typed Actors（Java）上的示例在Java中实现TypedActor 。但我在苦苦挣扎。我添加了akka-actor-1.1-M1.jar ， akka-typed-actor-1.1-M1.jar ， scala-library.jar但这还不够。我在Eclipse中遇到错误，所以我还在构建路径中添加了aspectwerkz-2.0.jar和aspectwerkz-core-2.0.jar 。我尝试使用带有自定义构造函数的TypedActor。但现在我在编译时遇到错误： Exception in thread “main” java.lang.NoSuchMethodError: org.codehaus.aspectwerkz.proxy.Proxy.newInstance([Ljava/lang/Class;[Ljava/lang/Object;ZZ)Ljava/lang/Object; at akka.actor.TypedActor$.newInstance(TypedActor.scala:596) at akka.actor.TypedActor$.newInstance(TypedActor.scala:634) at akka.actor.TypedActor.newInstance(TypedActor.scala) at com.example.actor.ActorTest.main(ActorTest.java:12) 这是我的BaseActor代码： import akka.actor.TypedActor; public class BaseActor extends TypedActor implements BaseService { private String str; private int num; public BaseActor(String str, int num) { this.str = str; this.num = […]

我应该使用Java中的哪个ThreadPool？: 有大量的任务。每个任务都属于一个组。要求是每组任务应该像在单个线程中执行一样串行执行，并且吞吐量应该在多核（或多CPU）环境中最大化。注意：还有大量的组与任务数量成比例。天真的解决方案是使用ThreadPoolExecutor并同步（或锁定）。但是，线程会相互阻塞，吞吐量不会最大化。有什么好主意吗？或者是否存在满足要求的第三方库？

使用guice注入与actor抛出空指针: 我在服务器的字段注入上获得空指针exception，该服务器作为akka actor启动。计划部分： private ActorRef myActor = Akka.system().actorOf( new Props(Retreiver.class)); @Override public void onStart(Application app) { log.info(“Starting schedular…..!”); Akka.system() .scheduler() .schedule(Duration.create(0, TimeUnit.MILLISECONDS), Duration.create(30, TimeUnit.MINUTES), myActor, “tick”, Akka.system().dispatcher()); } Retreiver类部分： public class Retreiver extends UntypedActor { private Logger.ALogger log = Logger.of(Retreiver .class); @Inject private myDataService dataService; @Override public void onReceive(Object arg0) throws Exception { if (0 […]