作者 邓超

es

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