我制作了一個 HTTP 服務(wù)器,并Echo存儲數(shù)據(jù)使用storm和數(shù)據(jù)模型,如下所示:項目1(桶)?device_type_1(桶)??設(shè)備_1(kv)??設(shè)備_2(kv)?device_type_2(桶)??設(shè)備_1(kv)??設(shè)備_2(kv)項目2(桶)?...除了更新數(shù)據(jù)庫之外,收到HTTP請求后還有一些其他事情要做,所以我使用這樣的事務(wù):tx, err := db.Begin(true)if err != nil { return}defer tx.Rollback()// for simplicityprojectBkt := tx.From("project1")projectBkt.Save(&project)// other things.......if err := tx.Commit(); err != nil { return}提交 Bolt 事務(wù)時很有可能出現(xiàn)鎖等待,堆棧如下所示:goroutine 53 [semacquire, 5 minutes]:sync.runtime_SemacquireMutex(0xc000002560, 0x16a7f00, 0x0) C:/Go/src/runtime/sema.go:71 +0x4esync.(*RWMutex).Lock(0xc000002558) C:/Go/src/sync/rwmutex.go:103 +0xc0go.etcd.io/bbolt.(*DB).mmap(0xc0000023c0, 0x20000, 0x0, 0x0) D:/data/Go/pkg/mod/go.etcd.io/bbolt@v1.3.0/db.go:246 +0x65go.etcd.io/bbolt.(*DB).allocate(0xc0000023c0, 0x1, 0x0, 0x0, 0x0) D:/data/Go/pkg/mod/go.etcd.io/bbolt@v1.3.0/db.go:846 +0x24bgo.etcd.io/bbolt.(*Tx).allocate(0xc000e98fc0, 0x1, 0x0, 0x0, 0x0) D:/data/Go/pkg/mod/go.etcd.io/bbolt@v1.3.0/tx.go:454 +0x79go.etcd.io/bbolt.(*node).spill(0xc0001539d0, 0x0, 0x0) D:/data/Go/pkg/mod/go.etcd.io/bbolt@v1.3.0/node.go:368 +0x3f0go.etcd.io/bbolt.(*Bucket).spill(0xc0001cb740, 0x0, 0x0) D:/data/Go/pkg/mod/go.etcd.io/bbolt@v1.3.0/bucket.go:541 +0x73ago.etcd.io/bbolt.(*Bucket).spill(0xc000e98fd8, 0x0, 0x0) D:/data/Go/pkg/mod/go.etcd.io/bbolt@v1.3.0/bucket.go:508 +0x64fgo.etcd.io/bbolt.(*Tx).Commit(0xc000e98fc0, 0x0, 0x0) D:/data/Go/pkg/mod/go.etcd.io/bbolt@v1.3.0/tx.go:163 +0x1bfgithub.com/asdine/storm.(*node).Commit(0xc0001cb380, 0x0, 0x0) D:/data/Go/pkg/mod/github.com/asdine/storm@v2.1.2+incompatible/transaction.go:46 +0x5c.....問題是如何檢測占用鎖的 goroutine 以便檢查整個操作順序?
如何檢測占用鎖的goroutine?
慕田峪4524236
2023-07-31 14:59:09