mirror of
https://github.com/datarhei/core.git
synced 2025-09-27 04:16:25 +08:00
Fix race condition
This commit is contained in:
@@ -589,7 +589,9 @@ func (p *process) stop(wait bool) error {
|
|||||||
p.callbacks.onExit = func() {
|
p.callbacks.onExit = func() {
|
||||||
wg.Done()
|
wg.Done()
|
||||||
|
|
||||||
|
p.callbacks.lock.Lock()
|
||||||
p.callbacks.onExit = nil
|
p.callbacks.onExit = nil
|
||||||
|
p.callbacks.lock.Unlock()
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
cb := p.callbacks.onExit
|
cb := p.callbacks.onExit
|
||||||
@@ -597,7 +599,9 @@ func (p *process) stop(wait bool) error {
|
|||||||
cb()
|
cb()
|
||||||
wg.Done()
|
wg.Done()
|
||||||
|
|
||||||
|
p.callbacks.lock.Lock()
|
||||||
p.callbacks.onExit = cb
|
p.callbacks.onExit = cb
|
||||||
|
p.callbacks.lock.Unlock()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
p.callbacks.lock.Unlock()
|
p.callbacks.lock.Unlock()
|
||||||
|
Reference in New Issue
Block a user