1

@@ -92,6 +92,8 @@ function start(){
                             // 协程结束后
                             co::defer(function ($id) use(&$cNum,$data){
                                 $cNum--;
+                                // 写入日志
+                                \Lib\Log::getInstance()->write();
                                 // 结束后要关闭数据库链接，不然链接一直暂用
                                 db()->close();
                                 // 删除占用

@@ -49,7 +49,7 @@ function start(){
                 // 需要同步的id
                 $id = redis()->lPop('sync_email_lists');
 
-                if(!$id){
+                if(!$id || !is_numeric($id)){
                     co::sleep(1);
                 }else{
                     // 占用当前的id,占用2小时