remved concurrent memory read

koss-null · Jan 27, 2024 · e757bcd · e757bcd
1 parent b81fbce
commit e757bcd
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/internal/internalpipe/any.go b/internal/internalpipe/any.go
@@ -1,6 +1,8 @@
 package internalpipe
 
-import "sync"
+import (
+	"sync"
+)
 
 const hugeLenStep = 1 << 15
 
@@ -65,9 +67,9 @@ func (p Pipe[T]) Any() *T {
 				}
 
 				for j := lf; j < rg; j++ {
-					// mx.Lock()
+					mx.Lock()
 					rs := resSet
-					// mx.Unlock()
+					mx.Unlock()
 					if !rs {
 						obj, skipped := p.Fn(j)
 						if !skipped {