2
0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-10 11:31:58 +08:00

Rename channel name

This commit is contained in:
Ken Hibino 2019-12-18 18:57:48 -08:00
parent 33e9da953d
commit 8b98b6e5a0

View File

@ -30,8 +30,8 @@ type processor struct {
done chan struct{} done chan struct{}
once sync.Once once sync.Once
// shutdown channel is closed when the shutdown of the "processor" goroutine starts. // abort channel is closed when the shutdown of the "processor" goroutine starts.
shutdown chan struct{} abort chan struct{}
// quit channel communicates to the in-flight worker goroutines to stop. // quit channel communicates to the in-flight worker goroutines to stop.
quit chan struct{} quit chan struct{}
@ -44,7 +44,7 @@ func newProcessor(r *rdb.RDB, numWorkers int, handler Handler) *processor {
dequeueTimeout: 2 * time.Second, dequeueTimeout: 2 * time.Second,
sema: make(chan struct{}, numWorkers), sema: make(chan struct{}, numWorkers),
done: make(chan struct{}), done: make(chan struct{}),
shutdown: make(chan struct{}), abort: make(chan struct{}),
quit: make(chan struct{}), quit: make(chan struct{}),
} }
} }
@ -55,7 +55,7 @@ func (p *processor) stop() {
p.once.Do(func() { p.once.Do(func() {
log.Println("[INFO] Processor shutting down...") log.Println("[INFO] Processor shutting down...")
// Unblock if processor is waiting for sema token. // Unblock if processor is waiting for sema token.
close(p.shutdown) close(p.abort)
// Signal the processor goroutine to stop processing tasks // Signal the processor goroutine to stop processing tasks
// from the queue. // from the queue.
p.done <- struct{}{} p.done <- struct{}{}
@ -109,7 +109,7 @@ func (p *processor) exec() {
} }
select { select {
case <-p.shutdown: case <-p.abort:
// shutdown is starting, return immediately after requeuing the message. // shutdown is starting, return immediately after requeuing the message.
p.requeue(msg) p.requeue(msg)
return return