我的职能是:
func New(config *WatcherConfig) *Watcher {
instance := &Watcher{
config: config,
connections: make(map[string]ConnectionInfo),
lock: sync.Mutex{},
}
go instance.Start()
return instance
}它创建了一个新的Watcher实例,目前有两个WatcherConfig。如您所见,我使用Go例程启动另一个名为Start()的函数。
func (w *Watcher) Start() {
fmt.Println(w.config.PathToLogFile)
}一个WatcherConfig的值为/var/log/openvpn.log表示PathToLogFile,另一个WatcherConfig的值为PathToLogFile。但是,当我使用一个Start()调用GoRoutine函数时,它会打印/var/log/postfix.log两次。如果我删除go例程,如下所示:
func New(config *WatcherConfig) *Watcher {
instance := &Watcher{
config: config,
connections: make(map[string]ConnectionInfo),
lock: sync.Mutex{},
}
instance.Start()
return instance
}现在它将正确地打印/var/log/openvpn.log和/var/log/postfix.log。
调用New()的代码
/// ---------
/// Parse config file
/// ---------
configuration, err := config.ParseConfig(*configFileLocation)
if err != nil {
log.Fatalln(err)
}
var watchers []*watcher.Watcher
for _, watcherConfig := range configuration.Watchers {
watchers = append(watchers, watcher.New(&watcherConfig))
}为什么go例程“切换”到另一个实例?
发布于 2021-10-16 13:31:25
如何修复:
for _, watcherConfig := range configuration.Watchers {
watcherConfig := watcherConfig // copy
watchers = append(watchers, watcher.New(&watcherConfig))
}Go中的Range循环是--重用迭代变量,也就是说,它们重新使用分配的内存来减少分配,在您的示例中是watcherConfig变量。因此,您要传递给带有New的New(&watcherConfig)的指针将指向相同的内存(因为它是重用的)。因此,所有的观察者最终都得到了相同的配置。
在New中没有goroutine的版本看起来工作正常,因为print语句输出当前存储在共享内存中的值,但是一旦循环结束,观察者将引用相同的配置。
有一个常见问题条目来讨论这个问题。
https://stackoverflow.com/questions/69595865
复制相似问题