Only wake Tx if they're still reading a modified value

1 files changed, 2 insertions, 0 deletions

diff --git a/funcs.go b/funcs.go
index 91d6bc8..80c25b1 100644
--- a/funcs.go
+++ b/funcs.go
@@ -71,7 +71,9 @@ retry:
 			time.Sleep(time.Duration(ns))
 		}
 	}
+	tx.mu.Lock()
 	ret, retry := catchRetry(op, tx)
+	tx.mu.Unlock()
 	if retry {
 		expvars.Add("retries", 1)
 		// wait for one of the variables we read to change before retrying