优化 同步

@@ -23,8 +23,20 @@ function start(){
         _echo("业务进程（{$worker_id}）启动成功");
         _echo("业务进程（{$worker_id}）启动成功");
 
 
         $goNum = 0;
         $goNum = 0;
+        $start_time = time();
         // 循环阻塞
         // 循环阻塞
         while (true){
         while (true){
+            // 每执行 12小时 就重启任务
+            if((time()-$start_time) > 43200){
+                if($goNum < 1 || (time()-$start_time) > 43300) break;
+                co::sleep(1);
+                continue;
+            }
+            if($goNum > 50){
+                co::sleep(0.5);
+                continue;
+//                break;
+            }
 
 
             // 需要同步的id
             // 需要同步的id
             $id = redis()->lPop('sync_email_lists');
             $id = redis()->lPop('sync_email_lists');
@@ -92,10 +104,6 @@ function start(){
             //每次都暂停1秒，防止同一时间启动太多的任务
             //每次都暂停1秒，防止同一时间启动太多的任务
             co::sleep(0.1);
             co::sleep(0.1);
 
 
-            while ($goNum > 50){
-                co::sleep(0.3);
-//                break;
-            }
 
 
         }
         }