Method ShutdownWithTimeout

pkg/actor/system.go:383–416

ShutdownWithTimeout 带超时的关闭

(timeout time.Duration)

// ShutdownWithTimeout 带超时的关闭
func (s *System) ShutdownWithTimeout(timeout time.Duration) {
	actorLog.Info(context.Background(), "system shutting down", map[string]any{"name": s.name})

	s.isRunning.Store(false)

	// 停止所有 Actor
	s.actorsMu.RLock()
	pids := make([]*PID, 0, len(s.actors))
	for _, cell := range s.actors {
		pids = append(pids, cell.pid)
	}
	s.actorsMu.RUnlock()

	for _, pid := range pids {
		s.Stop(pid)
	}

	// 取消上下文
	s.cancel()

	// 等待所有 goroutine 完成
	done := make(chan struct{})
	go func() {
		s.wg.Wait()
		close(done)
	}()

	select {
	case <-done:
		actorLog.Info(context.Background(), "system shutdown complete", map[string]any{"name": s.name})
	case <-time.After(timeout):
		actorLog.Warn(context.Background(), "system shutdown timeout, forcing exit", map[string]any{"name": s.name})
	}
}

// dispatcher 全局消息分发器
func (s *System) dispatcher() {