作者 赵彬吉

update

@@ -31,6 +31,7 @@ class SyncSubmitTask extends Command @@ -31,6 +31,7 @@ class SyncSubmitTask extends Command
31 while (true) { 31 while (true) {
32 $task_id = Redis::rpop('sync_submit_task'); 32 $task_id = Redis::rpop('sync_submit_task');
33 if(!$task_id){ 33 if(!$task_id){
  34 + sleep(1);
34 continue; 35 continue;
35 } 36 }
36 37
@@ -44,6 +44,8 @@ class SyncSubmitTaskDistribution extends Command @@ -44,6 +44,8 @@ class SyncSubmitTaskDistribution extends Command
44 $this->output('分发:' . $task->id); 44 $this->output('分发:' . $task->id);
45 } 45 }
46 } 46 }
  47 + }else{
  48 + sleep(1);
47 } 49 }
48 }catch (\Exception $e){ 50 }catch (\Exception $e){
49 $this->output('异常:' . $e->getMessage()); 51 $this->output('异常:' . $e->getMessage());