Method Request

pkg/actor/system.go:295–327

Request 同步请求（等待响应）

(target *PID, msg Message, timeout time.Duration)

// Request 同步请求（等待响应）
func (s *System) Request(target *PID, msg Message, timeout time.Duration) (Message, error) {
	if !s.isRunning.Load() {
		return nil, errors.New("actor system is not running")
	}

	// 使用 context 来取消请求
	ctx, cancel := context.WithTimeout(context.Background(), timeout)
	defer cancel()

	responseChan := make(chan Message, 1)
	env := envelope{
		target:   target,
		sender:   nil,
		message:  msg,
		sentAt:   time.Now(),
		response: responseChan,
		ctx:      ctx,
	}

	select {
	case s.mailbox <- env:
		atomic.AddInt64(&s.stats.TotalMessages, 1)
	case <-ctx.Done():
		return nil, &ResponseTimeout{Target: target, Timeout: timeout}
	}

	select {
	case resp := <-responseChan:
		return resp, nil
	case <-ctx.Done():
		return nil, &ResponseTimeout{Target: target, Timeout: timeout}
	}
}

// Stop 停止 Actor
func (s *System) Stop(pid *PID) {