diff options
| author | Valery Piashchynski <[email protected]> | 2021-12-14 13:21:12 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-12-14 13:21:12 +0300 |
| commit | 8c789bec56646342cc16818ef6c2f646aaa679f5 (patch) | |
| tree | d4d203806a13e6efe251d9c1a91f657a224207b5 /pool | |
| parent | 50944620fabb8cfa1d2bbbc50f64db457c4837ad (diff) | |
protect destroy operation with mutex
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pool')
| -rwxr-xr-x | pool/supervisor_pool.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/pool/supervisor_pool.go b/pool/supervisor_pool.go index b01520e2..3dbae417 100755 --- a/pool/supervisor_pool.go +++ b/pool/supervisor_pool.go @@ -87,8 +87,10 @@ func (sp *supervised) RemoveWorker(worker worker.BaseProcess) error { } func (sp *supervised) Destroy(ctx context.Context) { - sp.pool.Destroy(ctx) sp.Stop() + sp.mu.Lock() + sp.pool.Destroy(ctx) + sp.mu.Unlock() } func (sp *supervised) Start() { |