我正在尝试将数据存储区用作分布式锁。根据文档，我预计以下代码在datastore: concurrent transaction上会失败，但它只失败了<5%的时间。使用的数据库处于乐观并发模式。
我怎样才能让它锁定该实体并使任何并发读/写操作失败？
这段代码取自官方文档，在事务读写之间添加了一个Put。

ctx := context.Background()
    client, err := datastore.NewClientWithDatabase(ctx, "project-id", "database-id")
    if err != nil {
        panic(err)
    }

    type Counter struct {
        Count int
    }

    var count int
    key := datastore.NameKey("Counter", "singleton", nil)
    if _, err = client.RunInTransaction(ctx, func(tx *datastore.Transaction) error {
        var x Counter
        if err := tx.Get(key, &x); err != nil && err != datastore.ErrNoSuchEntity {
            return err
        }

        y := x
        y.Count = 10
        if _, err = client.Put(ctx, key, &y); err != nil {
            return err
        }

        x.Count++
        if _, err = tx.Put(key, &x); err != nil {
            return err
        }
        count = x.Count
        return nil
    }); err != nil {
        panic(err)
    }

    if err = client.Delete(ctx, key); err != nil {
        panic(err)
    }

    fmt.Println("COUNT:", count)