使用Java 手写一个简单的actor模型-只记录数据的
首先定义一个Actor接口,包含三个方法:onStart、onMessage和onStop。onStart方法在Actor启动时调用一次,onMessage方法在Actor接收到消息时调用,onStop方法在Actor停止时调用:public interface Actor<T> { void onS
首先定义一个 Actor 接口,包含三个方法:onStart、onMessage 和 onStop。onStart 方法在 Actor 启动时调用一次,onMessage 方法在 Actor 接收到消息时调用,onStop 方法在 Actor 停止时调用:
public interface Actor<T> {
void onStart();
void onMessage(T message);
void onStop();
}接下来实现一个简单的 ActorSystem 类,负责创建和管理 Actor。它包括一个名为 actors 的 Map,用于存储所有 Actor 实例:
import java.util.HashMap;
import java.util.Map;
public class ActorSystem {
private Map<String, Actor<?>> actors = new HashMap<>();
public <T> ActorRef<T> actorOf(Actor<T> actor, String name) {
// 创建 ActorRef,并将 Actor 加入 actors 中
ActorRef<T> actorRef = new ActorRef<>(actor, name);
actors.put(name, actor);
return actorRef;
}
public void原创不易,完成人机校验,阅读全文