租赁: LockWriteOps 范围分支竞争与租赁缓存变异

lc := leaseCache{ entries: map[string]leaseKey{ "k/initial": leaseKeyForLockWriteOpsRange("k/initial", 1), }, revokes: make(map[string]time.Time), header: &etcdserverpb.ResponseHeader{Revision: 1}, }, } ctx, cancel := context.WithTimeout(context.Background(), 100time.Millisecond) defer cancel()

donec := make(chan struct{}, 2) go func() { defer func() { donec <- struct{}{} }() for ctx.Err() == nil { wcs := lc.LockWriteOps([]clientv3.Op{ ...