Use uAtomic for atomic.Bool

apache · Feb 21, 2024 · 5066100 · 5066100
1 parent 05d5eca
commit 5066100
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar/consumer_impl.go b/pulsar/consumer_impl.go
@@ -20,10 +20,10 @@ package pulsar
 import (
 	"context"
 	"fmt"
+	uAtomic "go.uber.org/atomic"
 	"math/rand"
 	"strconv"
 	"sync"
-	"sync/atomic"
 	"time"
 
 	"github.com/apache/pulsar-client-go/pulsar/crypto"
@@ -714,7 +714,7 @@ func (c *consumer) hasNext() bool {
 
 	wg.Add(len(c.consumers))
 
-	var hasNext atomic.Bool
+	var hasNext uAtomic.Bool
 	for _, pc := range c.consumers {
 		pc := pc
 		go func() {