xlgo-core
wehub-resource-sync
61 行
1.9 KiB
Go
61 行
1.9 KiB
Go
package xlgo_test
|
||
|
||
import (
|
||
"os"
|
||
"path/filepath"
|
||
"runtime"
|
||
"testing"
|
||
"time"
|
||
|
||
xlgo "github.com/EthanCodeCraft/xlgo-core"
|
||
"github.com/EthanCodeCraft/xlgo-core/config"
|
||
)
|
||
|
||
// TestAppShutdownStopsConfigWatcher_Mconfig3 固化 M-config-3：App.Shutdown 须停止其
|
||
// configManager 的热重载 watcher，避免关闭后遗留监听 goroutine（违反 C7 生命周期契约）。
|
||
//
|
||
// Init 后 resolveConfig 把 a.configManager 提升为全局默认，故经包级 config.StartWatcher
|
||
// 在其上启动 watcher（等价于用户对 configManager 调 LoadWithWatch/StartWatcher）；
|
||
// Shutdown 后断言 watchLoop goroutine 已退出。
|
||
func TestAppShutdownStopsConfigWatcher_Mconfig3(t *testing.T) {
|
||
dir := filepath.Join(os.TempDir(), "xlgo_app_mconfig3")
|
||
if err := os.MkdirAll(dir, 0755); err != nil {
|
||
t.Fatalf("MkdirAll: %v", err)
|
||
}
|
||
defer os.RemoveAll(dir)
|
||
cfgPath := filepath.Join(dir, "config.yaml")
|
||
if err := os.WriteFile(cfgPath, []byte("app:\n name: m3\n env: dev\nserver:\n port: 18080\n"), 0644); err != nil {
|
||
t.Fatalf("WriteFile: %v", err)
|
||
}
|
||
|
||
app := xlgo.New(xlgo.WithConfigPath(cfgPath))
|
||
if err := app.Init(); err != nil {
|
||
t.Fatalf("Init: %v", err)
|
||
}
|
||
|
||
// 经全局默认（=a.configManager）启动 watcher，模拟用户开启热重载
|
||
if err := config.StartWatcher(); err != nil {
|
||
t.Fatalf("StartWatcher: %v", err)
|
||
}
|
||
defer config.SetDefaultManager(nil)
|
||
|
||
time.Sleep(120 * time.Millisecond) // 等 watchLoop 就绪
|
||
before := runtime.NumGoroutine()
|
||
|
||
if err := app.Shutdown(); err != nil {
|
||
t.Fatalf("Shutdown: %v", err)
|
||
}
|
||
|
||
// watchLoop goroutine 应随 Shutdown 退出
|
||
deadline := time.Now().Add(2 * time.Second)
|
||
for time.Now().Before(deadline) {
|
||
if runtime.NumGoroutine() < before {
|
||
break
|
||
}
|
||
time.Sleep(20 * time.Millisecond)
|
||
}
|
||
if after := runtime.NumGoroutine(); after >= before {
|
||
t.Errorf("App.Shutdown 未停止 config watcher（M-config-3）: before=%d after=%d", before, after)
|
||
}
|
||
}
|