From 83fb4cdcc76ae90df5871945a88964f3ebd56b84 Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Thu, 8 Jul 2021 21:28:43 -0400 Subject: [PATCH] increase gomaxprocs --- cmd/apollo-worker-notifications/main.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/cmd/apollo-worker-notifications/main.go b/cmd/apollo-worker-notifications/main.go index ecc389a..1129562 100644 --- a/cmd/apollo-worker-notifications/main.go +++ b/cmd/apollo-worker-notifications/main.go @@ -128,6 +128,8 @@ func main() { numConsumers := runtime.NumCPU() * 12 prefetchLimit := int64(numConsumers * 2) + runtime.GOMAXPROCS(numConsumers / 4) + if err := queue.StartConsuming(prefetchLimit, pollDuration); err != nil { panic(err) }