| 
...
 | 
...
 | 
@@ -43,7 +43,7 @@ function start(){ | 
| 
 | 
 | 
             if($id && is_numeric($id)){
 | 
| 
 | 
 | 
 
 | 
| 
 | 
 | 
                 // 占用当前的id,占用2小时
 | 
| 
 | 
 | 
                 if(redis()->add('just_sync_'.$id,time(),1200)){
 | 
| 
 | 
 | 
                 if(redis()->add('just_sync_'.$id,time(),600)){
 | 
| 
 | 
 | 
 //                    redis()->set('sync_my_pid:'.getmypid(),time(),86400);
 | 
| 
 | 
 | 
                     // 启动一个协程
 | 
| 
 | 
 | 
                     go(function () use ($id,&$goNum){
 | 
| 
...
 | 
...
 | 
@@ -73,7 +73,7 @@ function start(){ | 
| 
 | 
 | 
                         co::defer(function () use ($id,&$goNum){
 | 
| 
 | 
 | 
                             $goNum--;
 | 
| 
 | 
 | 
                             // 30秒后 消除占用
 | 
| 
 | 
 | 
                             redis()->expire('just_sync_'.$id,600);
 | 
| 
 | 
 | 
                             redis()->expire('just_sync_'.$id,120);
 | 
| 
 | 
 | 
                             // 写入日志
 | 
| 
 | 
 | 
                             \Lib\Log::getInstance()->write();
 | 
| 
 | 
 | 
                         });
 | 
...
 | 
...
 | 
 |