hibiken / asynq

Simple, reliable, and efficient distributed task queue in Go
MIT License
9k stars 659 forks source link

Feature: control queue concurrency #849

Closed kanzihuang closed 1 month ago

kanzihuang commented 3 months ago

// Config specifies the server's background-task processing behavior. type Config struct { // Maximum number of concurrent tasks of a queue. // // If set to a zero or not set, NewServer will not limit concurrency of the queue. QueueConcurrency map[string]int }

codecov[bot] commented 3 months ago

Codecov Report

Attention: Patch coverage is 91.66667% with 3 lines in your changes are missing coverage. Please review.

Project coverage is 68.85%. Comparing base (8df0bfa) to head (07d2722). Report is 2 commits behind head on master.

:exclamation: Current head 07d2722 differs from pull request most recent head 8f93c46. Consider uploading reports for the commit 8f93c46 to get more accurate results

Files Patch % Lines
internal/rdb/rdb.go 66.66% 3 Missing :warning:
Additional details and impacted files ```diff @@ Coverage Diff @@ ## master #849 +/- ## ========================================== + Coverage 68.41% 68.85% +0.43% ========================================== Files 27 28 +1 Lines 3841 3859 +18 ========================================== + Hits 2628 2657 +29 + Misses 929 915 -14 - Partials 284 287 +3 ```

:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Have feedback on the report? Share it here.

shuqingzai commented 3 months ago

I hope this PR can be merged quickly. The current priority queue cannot accurately control the number of consumers in different queues. ☺️