登录
首页 >  Golang >  Go问答

tikv api 中的 lockkey 有什么用?

来源:stackoverflow

时间:2024-04-16 13:30:37 107浏览 收藏

来到golang学习网的大家,相信都是编程学习爱好者,希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《tikv api 中的 lockkey 有什么用?》,介绍一下,希望对大家的知识积累有所帮助,助力实战开发!

问题内容

最近在看tikv的api文档。交易中有一个lockkey api。当我调用它进行操作时,我直接惊慌了。 我有几个问题?

  1. 我想知道为什么会恐慌
  2. lockkeys api 有何用途? 可以帮我吗
    txn1, txn2 := begin(), begin()
    fmt.println("txn1 before:", txn1.ispessimistic())
    txn1.setoption(kv.pessimistic, true)
    fmt.println("txn1 after:", txn1.ispessimistic())

    fmt.println("txn2 before:", txn2.ispessimistic())
    txn2.setoption(kv.pessimistic, true)
    fmt.println("txn2 after:", txn2.ispessimistic())

    err := txn1.set(k2, v22)
    if err != nil {
        panic(err)
    }
    err = txn1.set(k1, v22)
    if err != nil {
        panic(err)
    }
    lockctx1 := &kv.lockctx{forupdatets: txn1.startts(), waitstarttime: time.now()}
    err = txn1.lockkeys(context.background(), lockctx1, k1,k2)
    if err!=nil{
        panic(err)
    }
    err = txn2.set(k2, v23)
    if err != nil {
        panic(err)
    }
    err = txn2.set(k1, v23)
    if err != nil {
        panic(err)
    }
    lockctx2 := &kv.lockctx{forupdatets: txn2.startts(), waitstarttime: time.now()}
    err = txn2.lockkeys(context.background(), lockctx2, k1,k2)
    if err!=nil{
        panic(err)
    }
    err = txn1.commit(context.background())
    if err != nil {
        panic(err)
    }
    fmt.println(get(k2))
    err = txn2.commit(context.background())
    if err != nil {
        panic(err)
    }

恐慌堆栈是:

panic: runtime error: index out of range [0] with length 0
goroutine 1 [running]:
github.com/pingcap/tidb/store/tikv.actionpessimisticlock.handlesinglebatch(0xc0002d6380, 0xc00036c3c0, 0xc0002d6400, 0x4, 0x1, 0x2, 0x0, 0x0, 0x0, 0xc000288bd0, ...)
        /users/go/pkg/mod/github.com/pingcap/[email protected]/store/tikv/2pc.go:922 +0x1442
github.com/pingcap/tidb/store/tikv.(*twophasecommitter).doactiononbatches(0xc00036c3c0, 0xc0002d6400, 0x4d430e0, 0xc0002d6380, 0xc0002d6500, 0x1, 0x1, 0x0, 0x0)
        /users/go/pkg/mod/github.com/pingcap/[email protected]/store/tikv/2pc.go:678 +0x110
github.com/pingcap/tidb/store/tikv.(*twophasecommitter).doactionongroupmutations(0xc00036c3c0, 0xc0002d6400, 0x4d430e0, 0xc0002d6380, 0xc0002d6480, 0x1, 0x1, 0x2, 0x0)
        /users/go/pkg/mod/github.com/pingcap/[email protected]/store/tikv/2pc.go:623 +0x442
github.com/pingcap/tidb/store/tikv.(*twophasecommitter).doactiononmutations(0xc00036c3c0, 0xc0002d6400, 0x4d430e0, 0xc0002d6380, 0x0, 0x0, 0x0, 0xc000288bd0, 0x2, 0x2, ...)
        /users/go/pkg/mod/github.com/pingcap/[email protected]/store/tikv/2pc.go:513 +0x1c3
github.com/pingcap/tidb/store/tikv.(*twophasecommitter).pessimisticlockmutations(...)
        /users/go/pkg/mod/github.com/pingcap/[email protected]/store/tikv/2pc.go:1291
github.com/pingcap/tidb/store/tikv.(*tikvtxn).lockkeys(0xc0000f60c0, 0x4d44e60, 0xc00012c000, 0xc0002d6380, 0xc000288ba0, 0x2, 0x2, 0x0, 0x0)
        /users/go/pkg/mod/github.com/pingcap/[email protected]/store/tikv/txn.go:446 +0x5f9
main.testtxn(0xc00003e068, 0x4, 0x4, 0xc00003e088, 0x4, 0x4, 0xc00003e096, 0x7, 0x7, 0xc00003e0a0, ...)

它发生在疼痛发生的地方,m为零

go mod 如下

go 1.14

require (
    github.com/juju/errors v0.0.0-20200330140219-3fe23663418f
    github.com/juju/testing v0.0.0-20210324180055-18c50b0c2098 // indirect
    github.com/pingcap/parser v0.0.0-20210107054750-53e33b4018fe
    github.com/pingcap/tidb v1.1.0-beta.0.20210419034717-00632fb3c710
    golang.org/x/net v0.0.0-20210226172049-e18ecbb05110
)


正确答案


对于问题2,lockKeys将锁定您在KVStore(TiKV)中提供的密钥的条目

对于问题1,请分享整个恐慌堆栈。

今天关于《tikv api 中的 lockkey 有什么用?》的内容就介绍到这里了,是不是学起来一目了然!想要了解更多关于的内容请关注golang学习网公众号!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>