1
type Actor struct {
2
    state   interface{}
3
    mailbox chan interface{}
4
    handler func(state interface{}, msg interface{}) interface{}
5
}
6

7
func NewActor(initial interface{},
8
    handler func(interface{}, interface{}) interface{}) *Actor {
9
    a := &Actor{
10
        state:   initial,
11
        mailbox: make(chan interface{}, 100),
12
        handler: handler,
13
    }
14
    go a.run() // 启动 Actor 的消息循环
15
    return a
16
}
17

18
func (a *Actor) Send(msg interface{}) {
19
    a.mailbox <- msg
20
}
21

22
func (a *Actor) run() {
23
    // 一次只处理一条消息，天然串行
24
    for msg := range a.mailbox {
25
        a.state = a.handler(a.state, msg)
26
    }
27
}

1
type MessageHandler<S> = (state: S, msg: unknown) => S;
2

3
class Actor<S> {
4
  private state: S;
5
  private mailbox: unknown[] = [];
6
  private processing = false;
7

8
  constructor(initialState: S, private handler: MessageHandler<S>) {
9
    this.state = initialState;
10
  }
11

12
  send(msg: unknown): void {
13
    this.mailbox.push(msg);
14
    if (!this.processing) this.processMailbox();
15
  }
16

17
  private processMailbox(): void {
18
    this.processing = true;
19
    while (this.mailbox.length > 0) {
20
      const msg = this.mailbox.shift()!;
21
      this.state = this.handler(this.state, msg);
22
    }
23
    this.processing = false;
24
  }
25

26
  getState(): S {
27
    return this.state;
28
  }
29
}
30

31
// 使用示例：计数器 Actor
32
const counter = new Actor({ count: 0 }, (state, msg) => {
33
  if (msg === 'increment') return { count: state.count + 1 };
34
  if (msg === 'decrement') return { count: state.count - 1 };
35
  return state;
36
});
37
counter.send('increment');
38
counter.send('increment');