多个进程开启定时任务，执行时间还是同时，可否时间不变，不同时执行

xiaoming 2024-04-16

问题描述

public static function onWorkerStart($worker)
{

        Timer::add(5, function () {
            if(empty(self::$heartbeat_queue)){
                return;
            }
            StoreWs::where("id", 'in', self::$heartbeat_queue)->update(['heartbeat_time' => time()]);
            self::$heartbeat_queue = [];
        });
}

 449  3 0

3个回答

xiaoming 2024-04-16

可这样子嵌套？

  Timer::add($worker->id+1, function () {
            Timer::add(5, function () {
                if(empty(self::$heartbeat_queue)){
                    return;
                }
                StoreWs::where("id", 'in', self::$heartbeat_queue)->update(['heartbeat_time' => time()]);
                self::$heartbeat_queue = [];
            });
        },[],false);

rbb 2024-04-16

这样不用嵌套了吧，Timer::add(5+$worker->id, function () {}
xiaoming 2024-04-17

周期就不是都5秒了

释永战 2024-04-16

Timer::add前面加一句sleep($worker->id);

xiaoming 2024-04-17

这样子不太好
释永战 2024-04-17

是哪里不太好？我就是用的这种方案，用了十几年了目前没有任何问题····

ichynul 2024-04-17

估计你是想任务在不同进程不同时执行吧，我做过类似的，把任务按顺序分配到不同的进程。

$threadTotal = $worker->count; //总进程数量 n
$threadId = $worker->id; //当前进程编号 1 ~ (n-1)
$i = -1;
foreach ($taskList as $li) {
     $i += 1;
     if ($i % $threadTotal != $threadId) {
          continue;
     }
     $this->curl($li['url']);
}

xiaoming 2024-04-17

是的周期都是5秒定时但是不同时刻执行

ichynul 2024-04-17

$queueIds = [];
foreach (self::$heartbeat_queue as $i => $q) {
     if ($i % $threadTotal != $threadId) {
          continue;
     }
    $queueIds[]= $q;
    unset(self::$heartbeat_queue[$i]);
}

StoreWs::where("id", 'in', $queueIds)->update(['heartbeat_time' => time()]);

同时执行，但不同的进程不会对同一个queueId重复执行。

相似问题

AsyncTcpConnection 多个进程同时执行问题

crontab定时任务组件，没有按时间执行

webman process进程定时任务卡死不执行

Timer执行任务时间问题

长时间执行定时任务(至少2个小时，1s执行一次)，需要注意什么

tp6 怎样同时开启websocket协议和运行多个定时任务？