yuxh/gearman-go
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

Fixed

Browse Source
This commit is contained in:
Dmitry Krylov 2022-01-04 15:46:55 +03:00
parent a20b263b9e
commit 3b13a9f51d
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
worker/worker.go
View File

@ -231,8 +231,10 @@ func (worker *Worker) Stop() {
// Wait for completeness serving // Wait for completeness serving
func (worker *Worker) WaitRunning() { func (worker *Worker) WaitRunning() {
// Wait for all the running activities has stopped // Wait for all the running activities has stopped
if worker.stopped {
worker.active.Wait() worker.active.Wait()
} }
}
// Close connection and exit main loop // Close connection and exit main loop
func (worker *Worker) Close() { func (worker *Worker) Close() {