$arrConfig = C($p_strConfigName);
if (empty($arrConfig)) {
die("error config");
}
var_dump($arrConfig);
try {
$pWorker = new \GearmanWorker();
$pWorker->addServer($arrConfig['host'], $arrConfig['port']) ;
$pWorker->addFunction($p_strTaskName, $p_strFuncName);
Log::record("hahah111", Log::ERR);
var_dump($pWorker);
while ($pWorker->work()) {
Log::record("hahah", Log::ERR);
sleep(2);
}
echo $pWorker->getErrno ();
} catch (\Exception $e) {
var_dump($e->getMessage());
}
}
最佳答案