代码拉取完成,页面将自动刷新
同步操作将从 go-locks/distlock 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
package distlock
import (
"errors"
"fmt"
"sync"
"github.com/go-locks/distlock/driver"
"github.com/go-locks/distlock/mutex"
)
type Distlock struct {
sync.Mutex
prefix string
driver driver.IDriver
mtxMap map[string]*mutex.Mutex
rwMtxMap map[string]*mutex.RWMutex
}
func New(driver driver.IDriver, optFuncs ...OptFunc) *Distlock {
dl := Distlock{
driver: driver,
prefix: "distlock-",
mtxMap: make(map[string]*mutex.Mutex),
rwMtxMap: make(map[string]*mutex.RWMutex),
}
for _, optFunc := range optFuncs {
optFunc(&dl)
}
return &dl
}
func (dl *Distlock) buildName(name string) string {
return dl.prefix + name
}
func (dl *Distlock) NewMutex(name string, optFuncs ...mutex.OptFunc) (*mutex.Mutex, error) {
dl.Lock()
defer dl.Unlock()
if _, ok := dl.mtxMap[name]; ok {
return dl.mtxMap[name], nil
} else if _, ok := dl.rwMtxMap[name]; ok {
return nil, fmt.Errorf("a rw mutex named '%s' already exist, instead of mutex", name)
}
dl.mtxMap[name] = mutex.NewMutex(dl.buildName(name), dl.driver, optFuncs...)
return dl.mtxMap[name], nil
}
func (dl *Distlock) NewRWMutex(name string, optFuncs ...mutex.OptFunc) (*mutex.RWMutex, error) {
dl.Lock()
defer dl.Unlock()
rwDriver, ok := dl.driver.(driver.IRWDriver)
if !ok {
return nil, errors.New("the driver is not a rw driver, so you can not create rw mutex")
}
if _, ok := dl.rwMtxMap[name]; ok {
return dl.rwMtxMap[name], nil
} else if _, ok := dl.mtxMap[name]; ok {
return nil, fmt.Errorf("a mutex named '%s' already exist, instead of rw mutex", name)
}
dl.rwMtxMap[name] = mutex.NewRWMutex(dl.buildName(name), rwDriver, optFuncs...)
return dl.rwMtxMap[name], nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。