x

@@ -34,10 +34,7 @@ function start(){
             // 需要同步的id
             $id = redis()->lPop('sync_email_lists');
 
-            if(!$id || !is_numeric($id)){
-                co::sleep(1);
-            }
-            else{
+            if($id && is_numeric($id)){
                 // 占用当前的id,占用2小时
                 if(redis()->add('just_sync_'.$id,time(),600)){
                     // 启动一个协程
@@ -63,7 +60,11 @@ function start(){
 
                     });
                 }
+            }else{
+                co::sleep(1);
             }
+            //每次都暂停1秒，防止同一时间启动太多的任务
+            co::sleep(0.5);
         }
 
     },true);