diff --git a/application/admin/queue/task/Listen.php b/application/admin/queue/task/Listen.php index 662bde6b4..8432a276e 100644 --- a/application/admin/queue/task/Listen.php +++ b/application/admin/queue/task/Listen.php @@ -49,7 +49,9 @@ class Listen extends Task protected function execute(Input $input, Output $output) { $output->comment('============ 异步任务监听中 ============'); - cli_set_process_title("ThinkAdmin {$this->version} 异步任务监听主进程"); + if ($this->isWin() && function_exists('cli_set_process_title')) { + cli_set_process_title("ThinkAdmin {$this->version} 异步任务监听主进程"); + } while (true) { $map = [['status', 'eq', '1'], ['time', '<=', time()]]; foreach (Db::name('SystemQueue')->where($map)->order('time asc')->select() as $item) { diff --git a/application/admin/queue/task/Work.php b/application/admin/queue/task/Work.php index 05b1fc7f6..849b9d189 100644 --- a/application/admin/queue/task/Work.php +++ b/application/admin/queue/task/Work.php @@ -67,8 +67,10 @@ class Work extends Task if (empty($this->id)) throw new Exception("执行任务需要指定任务编号!"); $queue = Db::name('SystemQueue')->where(['id' => $this->id, 'status' => '2'])->find(); if (empty($queue)) throw new Exception("执行任务{$this->id}的信息或状态异常!"); + if ($this->isWin() && function_exists('cli_set_process_title')) { + cli_set_process_title("ThinkAdmin {$this->version} 异步任务执行子进程 - {$queue['title']}"); + } // 设置进程标题 - cli_set_process_title("ThinkAdmin {$this->version} 异步任务执行子进程 - {$queue['title']}"); // 执行任务内容 if (class_exists($queue['preload'])) { if (method_exists($class = new $queue['preload'], 'execute')) {