x

@@ -55,8 +55,8 @@ function start(){
 
 
                         // 协程完成后执行的函数
                         // 协程完成后执行的函数
                         co::defer(function () use ($id){
                         co::defer(function () use ($id){
-                            // 消除占用
-                            redis()->delete('just_sync_'.$id);
+                            // 30秒后 消除占用
+                            redis()->expire('just_sync_'.$id,30);
                             // 写入日志
                             // 写入日志
                             \Lib\Log::getInstance()->write();
                             \Lib\Log::getInstance()->write();
                         });
                         });

@@ -70,6 +70,18 @@ trait RedisQuery {
         return $this->getClient()->set($key,$this->serialize($val),$ttl);
         return $this->getClient()->set($key,$this->serialize($val),$ttl);
     }
     }
 
 
+    /**
+     * 设置 缓存过期时间
+     * @param $key
+     * @param int $ttl
+     * @return bool
+     * @author：dc
+     * @time 2024/7/8 11:50
+     */
+    public function expire($key,$ttl = -1){
+        return $this->getClient()->expire($key,$ttl);
+    }
+
 
 
     /**
     /**
      * 如果有key返回false，没有则新增
      * 如果有key返回false，没有则新增