Method StopGracefully

pkg/actor/system.go:349–375

StopGracefully 优雅停止 Actor（等待处理完当前消息）

(pid *PID, timeout time.Duration)

// StopGracefully 优雅停止 Actor（等待处理完当前消息）
func (s *System) StopGracefully(pid *PID, timeout time.Duration) error {
	s.Stop(pid)

	// 等待状态变为 stopped
	deadline := time.Now().Add(timeout)
	for time.Now().Before(deadline) {
		s.actorsMu.RLock()
		cell, exists := s.actors[pid.ID]
		s.actorsMu.RUnlock()

		if !exists {
			return nil
		}

		cell.stateMu.RLock()
		state := cell.state
		cell.stateMu.RUnlock()

		if state == actorStateStopped {
			return nil
		}

		time.Sleep(10 * time.Millisecond)
	}

	return fmt.Errorf("timeout waiting for actor %s to stop", pid.ID)
}

// Shutdown 关闭整个 Actor 系统
func (s *System) Shutdown() {