v0.0.27

syncext/atomic.go

@@ -13,9 +13,9 @@ type AtomicBool struct {
 
 func NewAtomicBool(value bool) *AtomicBool {
 	if value {
-		return &AtomicBool{v: 0, waiter: make(chan bool)}
-	} else {
 		return &AtomicBool{v: 1, waiter: make(chan bool)}
+	} else {
+		return &AtomicBool{v: 0, waiter: make(chan bool)}
 	}
 }
 
@@ -56,6 +56,12 @@ func (a *AtomicBool) Wait(waitFor bool) {
 	}
 }
 
+func (a *AtomicBool) WaitWithTimeout(timeout time.Duration, waitFor bool) error {
+	ctx, cancel := context.WithTimeout(context.Background(), timeout)
+	defer cancel()
+	return a.WaitWithContext(ctx, waitFor)
+}
+
 func (a *AtomicBool) WaitWithContext(ctx context.Context, waitFor bool) error {
 	if err := ctx.Err(); err != nil {
 		return err