diff --git a/v1/brokers/redis/goredis.go b/v1/brokers/redis/goredis.go
index 7cf2e66b..161bc87f 100644
--- a/v1/brokers/redis/goredis.go
+++ b/v1/brokers/redis/goredis.go
@@ -77,7 +77,7 @@ func (b *BrokerGR) StartConsuming(consumerTag string, concurrency int, taskProce
 	defer b.consumingWG.Done()
 
 	if concurrency < 1 {
-		concurrency = runtime.NumCPU() * 2
+		concurrency = runtime.GOMAXPROCS(0) * 2
 	}
 
 	b.Broker.StartConsuming(consumerTag, concurrency, taskProcessor)
diff --git a/v1/brokers/redis/redis.go b/v1/brokers/redis/redis.go
index 1683f13e..513cec19 100644
--- a/v1/brokers/redis/redis.go
+++ b/v1/brokers/redis/redis.go
@@ -65,7 +65,7 @@ func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcess
 	defer b.consumingWG.Done()
 
 	if concurrency < 1 {
-		concurrency = runtime.NumCPU() * 2
+		concurrency = runtime.GOMAXPROCS(0) * 2
 	}
 
 	b.Broker.StartConsuming(consumerTag, concurrency, taskProcessor)
diff --git a/v2/brokers/redis/goredis.go b/v2/brokers/redis/goredis.go
index 82b5347c..57ced707 100644
--- a/v2/brokers/redis/goredis.go
+++ b/v2/brokers/redis/goredis.go
@@ -72,7 +72,7 @@ func (b *BrokerGR) StartConsuming(consumerTag string, concurrency int, taskProce
 	defer b.consumingWG.Done()
 
 	if concurrency < 1 {
-		concurrency = runtime.NumCPU() * 2
+		concurrency = runtime.GOMAXPROCS(0) * 2
 	}
 
 	b.Broker.StartConsuming(consumerTag, concurrency, taskProcessor)
diff --git a/v2/brokers/redis/redis.go b/v2/brokers/redis/redis.go
index eeb3ca78..1edbf165 100644
--- a/v2/brokers/redis/redis.go
+++ b/v2/brokers/redis/redis.go
@@ -65,7 +65,7 @@ func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcess
 	defer b.consumingWG.Done()
 
 	if concurrency < 1 {
-		concurrency = runtime.NumCPU() * 2
+		concurrency = runtime.GOMAXPROCS(0) * 2
 	}
 
 	b.Broker.StartConsuming(consumerTag, concurrency, taskProcessor)