x

@@ -15,6 +15,8 @@ function start(){
     swoole_set_process_name('php-email-sync-list-check');
     swoole_set_process_name('php-email-sync-list-check');
 
 
     $id = 0;
     $id = 0;
+
+    $goNum = 0;
     // 循环阻塞
     // 循环阻塞
     while (true){
     while (true){
 
 
@@ -22,7 +24,8 @@ function start(){
 
 
         if($id){
         if($id){
             // 启动一个协程
             // 启动一个协程
-            go(function () use ($id){
+            go(function () use ($id,&$goNum){
+                $goNum++;
                 // 开始同步
                 // 开始同步
                 try {
                 try {
                     sync($id);
                     sync($id);
@@ -30,15 +33,21 @@ function start(){
                     echo $e->getMessage();
                     echo $e->getMessage();
                 }
                 }
                 \Lib\Log::getInstance()->write();
                 \Lib\Log::getInstance()->write();
+
+                co::defer(function () use (&$goNum){
+                    $goNum--;
+                });
             });
             });
 
 
         }else{
         }else{
-            //每次都暂停1秒，防止同一时间启动太多的任务
-            co::sleep(300);
             break;
             break;
         }
         }
     }
     }
 
 
+    while ($goNum>0){
+        co::sleep(1);
+    }
+    _echo('结束了');
 }
 }
 
 
 /**
 /**