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

Added graceful stop for worker

Browse Source
This commit is contained in:
Dmitry Krylov 2022-01-03 21:25:22 +03:00
parent d36dcb7fc2
commit 2263172a84
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
worker/worker.go
View File

@ -219,6 +219,15 @@ func (worker *Worker) customeHandler(inpack *inPack) {
} }
} }
// Stop serving
func (worker *Worker) Stop() {
worker.Lock()
defer worker.Unlock()
if worker.running == true {
close(worker.in)
}
}
// Close connection and exit main loop // Close connection and exit main loop
func (worker *Worker) Close() { func (worker *Worker) Close() {
worker.Lock() worker.Lock()