每個(gè)worker實(shí)例進(jìn)程都有唯一的編號(hào),即: $worker->id 屬性,可以據(jù)此設(shè)置定時(shí)器,比如:
$worker->count = 4;
$worker->onWorkerStart = function($worker)
{
//比如:只給id為0的進(jìn)程設(shè)置定時(shí)器
if($worker->id === 0)
{
Timer::add(1, function(){
pprint("共啟動(dòng)了4個(gè)worker進(jìn)程,只給0號(hào)進(jìn)程設(shè)置定時(shí)器");
});
}
};
onmessage里面的參數(shù)沒看到有woker呢 怎么獲取進(jìn)程id呢
onMessage($connection, $data) 回調(diào)有$connection對象, 通過 $connection->woker 路由。