31 lines
540 B
Go
31 lines
540 B
Go
package trade
|
||
|
||
import (
|
||
"time"
|
||
|
||
cache "github.com/patrickmn/go-cache"
|
||
)
|
||
|
||
var MemCache *cache.Cache
|
||
|
||
func NewLock() {
|
||
if MemCache != nil {
|
||
return
|
||
}
|
||
MemCache = cache.New(5*time.Minute, 10*time.Minute)
|
||
}
|
||
|
||
// 锁仓，可以采用MemCache,Redis,File等。
|
||
func IsLock(symbol, side string) bool {
|
||
lockKey := symbol + ":" + side
|
||
_, found := MemCache.Get(lockKey)
|
||
if found {
|
||
return true
|
||
}
|
||
return false
|
||
}
|
||
|
||
func SetLock(symbol, side string, duration int64) {
|
||
MemCache.Set(symbol+":"+side, true, time.Duration(duration)*time.Second)
|
||
}
|