正在显示
2 个修改的文件
包含
4 行增加
和
3 行删除
@@ -25,7 +25,8 @@ class SendJob { | @@ -25,7 +25,8 @@ class SendJob { | ||
25 | */ | 25 | */ |
26 | private function isStop(){ | 26 | private function isStop(){ |
27 | // 运行超过1天的 停止 | 27 | // 运行超过1天的 停止 |
28 | - if($this->run_timer < (time()-86400)){ | 28 | + if($this->run_timer < (time()-43200)){ |
29 | + @posix_kill(getmypid(), SIGTERM); | ||
29 | return true; | 30 | return true; |
30 | } | 31 | } |
31 | return redis()->get('send_job_is_stop') == 'stop'; | 32 | return redis()->get('send_job_is_stop') == 'stop'; |
@@ -26,7 +26,7 @@ function start(){ | @@ -26,7 +26,7 @@ function start(){ | ||
26 | while (true){ | 26 | while (true){ |
27 | 27 | ||
28 | // 运行超过1天的 停止 | 28 | // 运行超过1天的 停止 |
29 | - if($run_timer < (time()-86400)){ | 29 | + if($run_timer < (time()-43200)){ |
30 | break; | 30 | break; |
31 | } | 31 | } |
32 | 32 | ||
@@ -78,7 +78,7 @@ function start(){ | @@ -78,7 +78,7 @@ function start(){ | ||
78 | // 循环阻塞 | 78 | // 循环阻塞 |
79 | while (true){ | 79 | while (true){ |
80 | // 运行超过1天的 停止 | 80 | // 运行超过1天的 停止 |
81 | - if($run_timer < (time()-86400)){ | 81 | + if($run_timer < (time()-43200)){ |
82 | break; | 82 | break; |
83 | } | 83 | } |
84 | // 需要同步的id | 84 | // 需要同步的id |
-
请 注册 或 登录 后发表评论