提交 571172b6 编写于 作者: 梦境迷离's avatar 梦境迷离

fix lock

上级 94d4b70c
......@@ -47,7 +47,7 @@ object Implicits {
val key = cacheKey(identities)
val field = cacheField(args)
val locked = s"$key-$field"
locked.synchronized {
locked.synchronized { // TODO redis lock
for {
cacheValue <- ZStream.fromEffect(ZCaffeine.hGet[T](key, field))
_ <- if (ZCaffeine.disabledLog) ZStream.unit else LogUtils.debugS(s"Caffeine ZStream getIfPresent: identity:[$key],field:[$field],cacheValue:[$cacheValue]")
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册