Skip to content

chore(queue): auto scale the task worker #44

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 7 commits into from
Mar 27, 2022
Merged

chore(queue): auto scale the task worker #44

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
73f5262
chore(queue): auto scale the task worker
appleboy Mar 27, 2022
7cf1346
chore: update
appleboy Mar 27, 2022
d631bc5
chore: update
appleboy Mar 27, 2022
2c37dd1
chore: update
appleboy Mar 27, 2022
c4b8d92
chore: update
appleboy Mar 27, 2022
f1896c4
chore: update
appleboy Mar 27, 2022
d3c2e69
chore: update
appleboy Mar 27, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
chore: update 
Signed-off-by: Bo-Yi Wu <[email protected]>
  • Loading branch information
@appleboy
appleboy committed Mar 27, 2022
commit c4b8d921616dd1e6b8a21d87759ba98288350dca
12 changes: 9 additions & 3 deletions queue.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -253,7 +253,9 @@ func (q *Queue) start() {
select {
case task = <-tasks:
// queue task before shutdown the service
_ = q.worker.Queue(task)
if err := q.worker.Queue(task); err != nil {
q.logger.Errorf("can't re-queue message: %v", err)
}
default:
}
return
Expand All @@ -267,12 +269,16 @@ func (q *Queue) start() {
// get worker to execute new task
select {
case <-q.quit:
_ = q.worker.Queue(task)
if err := q.worker.Queue(task); err != nil {
q.logger.Errorf("can't re-queue message: %v", err)
}
return
case <-q.ready:
select {
case <-q.quit:
_ = q.worker.Queue(task)
if err := q.worker.Queue(task); err != nil {
q.logger.Errorf("can't re-queue message: %v", err)
}
return
default:
}
Expand Down