队列实现优化

Author: kiss291323003

src/Driver/Pool/RedisPool.php

@@ -15,13 +15,15 @@ protected function createObject()
         /** @var Config $config */
         $config = $this->getConfig()->getExtraConf();
         if($config instanceof ClusterConfig){
-            $info = new RedisCluster($config);
-            $info->connect();
-            return $info;
+            $item = new RedisCluster($config);
+            $item->connect();
+            $item->__lastPingTime = 0;
+            return $item;
         }else{
-            $info = new Redis($config);
-            $info->connect();
-            return $info;
+            $item = new Redis($config);
+            $item->connect();
+            $item->__lastPingTime = 0;
+            return $item;
         }
     }
 
@@ -48,9 +50,6 @@ public function keepMin(?int $num = null): int
      */
     protected function itemIntervalCheck($item): bool
     {
-        if(!isset($item->__lastPingTime)){
-            $item->__lastPingTime = 0;
-        }
         if(time() - $item->__lastPingTime > 10){
             try{
                 $ret = $item->ping();