GatewayWorker的定時(shí)器,如何向workman一樣指定某個(gè)進(jìn)程去定時(shí)執(zhí)行
類似:
$worker->onWorkerStart = function($worker)
{
// 只在id編號(hào)為0的進(jìn)程上設(shè)置定時(shí)器,其它1、2、3號(hào)進(jìn)程不設(shè)置定時(shí)器
if($worker->id === 0)
{
Timer::add(1, function(){
echo "4個(gè)worker進(jìn)程,只在0號(hào)進(jìn)程設(shè)置定時(shí)器\n";
});
}
};
現(xiàn)在有個(gè)需求就是,每隔10秒向所有客戶端廣播一次消息,但如果開了4個(gè)進(jìn)程,那這條消息就會(huì)發(fā)送4次,所以想在定時(shí)器與某個(gè)進(jìn)程的id綁定,專門由這個(gè)進(jìn)程去廣播
public static function onWorkerStart($businessWorker)
{
if ($businessWorker->id == 0) {
}
}