本文介绍如何在 go 语言中模拟类似 qt 的 property notify 机制，通过通道（channel）实现一个中心化属性值变更时向多个监听者广播更新事件的轻量级方案。
在 Go 这样没有原生属性（property）和信号槽（signal-slot）机制的语言中，若需实现“某值变更 → 多个 UI 组件/逻辑模块同步响应”的典型场景（例如进度值同时驱动进度条与百分比文本），可借助 Go 的并发原语——尤其是带缓冲的通道（chan T）——构建一个简易但高效的发布-订阅式通知系统。
核心思路是：将属性状态与通知通道解耦，由中心管理器统一维护当前值，并在每次修改后向所有注册的监听通道广播新值。监听方通过 for range 持续消费该通道，实现异步、非阻塞的响应。
以下是一个完整、可运行的示例实现：
package main
import (
"fmt"
"time"
)
// 全局状态（模拟被监听的“属性”）
var progress int
// 所有监听通道的集合（注意：生产环境建议加锁保护）
var listeners []chan int
// GetChan 返回一个新的监听通道，并将其注册到全局列表
func GetChan() chan int {
ch := make(chan int, 5) // 缓冲区避免发送阻塞（尤其在监听者暂未读取时）
listeners = append(listeners, ch)
return ch
}
// Set 更新属性值，并向所有监听者广播
func Set(newVal int) {
progress = newVal
for _, ch := range listeners {
select {
case ch <- progress:
// 成功发送
default:
// 缓冲满时跳过（或可记录警告、丢弃旧值、扩容等策略）
}
}
}
// Background 是一个典型的监听协程：持续接收并处理变更事件
func Background(name string, ch chan int, done chan struct{}) {
defer func() { done <- struct{}{} }()
for val := range ch {
fmt.Printf("[%s] progress updated to: %d%%\n", name, val)
}
}
func main() {
// 创建两个监听者
ch1 := GetChan()
ch2 := GetChan()
done := make(chan struct{}, 2)
go Background("ProgressBar", ch1, done)
go Background("PercentageLabel", ch2, done)
// 触发两次变更
Set(30)
time.Sleep(100 * time.Millisecond)
Set(75)
time.Sleep(100 * time.Millisecond)
Set(100)
// 安全关闭所有监听通道（防止 goroutine 泄漏）
for _, ch := range listeners {
close(ch)
}
// 等待监听协程退出
<-done
<-done
fmt.Println("All listeners stopped.")
}关键设计说明：
- ✅ 缓冲通道：使用 make(chan int, 5) 避免因监听者处理延迟导致 Set() 调用阻塞，提升响应鲁棒性；
- ✅ 非阻塞发送：select { case ch
- ✅ 资源清理：显式 close(ch) 并配合 for range 自然退出，确保 goroutine 正常终止；
- ⚠️ 并发安全提示：当前示例中 listeners 切片未加锁，仅适用于单写（如初始化+主 goroutine 修改）场景；若需动态增删监听者，应使用 sync.RWMutex 或 sync.Map 封装；
- ? 扩展建议：对于更复杂需求（如按 topic 订阅、取消订阅、消息类型泛型化），可封装为 EventBroker 结构体，参考 Stack Overflow 中的 broadcast channel 实现。
该模式简洁、零依赖、符合 Go 的 CSP 哲学，是中小型项目中实现跨组件状态响应的理想起点。
