正在显示
1 个修改的文件
包含
0 行增加
和
6 行删除
@@ -22,16 +22,10 @@ function start(){ | @@ -22,16 +22,10 @@ function start(){ | ||
22 | include_once __DIR__."/../vendor/autoload.php"; | 22 | include_once __DIR__."/../vendor/autoload.php"; |
23 | _echo("业务进程({$worker_id})启动成功"); | 23 | _echo("业务进程({$worker_id})启动成功"); |
24 | 24 | ||
25 | - $run_timer = time(); | ||
26 | $goNum = 0; | 25 | $goNum = 0; |
27 | // 循环阻塞 | 26 | // 循环阻塞 |
28 | while (true){ | 27 | while (true){ |
29 | 28 | ||
30 | - // 运行超过1天的 停止 | ||
31 | - if($run_timer < (time()-21600)){ | ||
32 | - break; | ||
33 | - } | ||
34 | - | ||
35 | // 需要同步的id | 29 | // 需要同步的id |
36 | $id = redis()->lPop('sync_email_lists'); | 30 | $id = redis()->lPop('sync_email_lists'); |
37 | 31 |
-
请 注册 或 登录 后发表评论