首页 > 代码库 > gearman中任务的优先级和返回状态
gearman中任务的优先级和返回状态
gearman中任务的优先级和返回状态
一、任务的优先级
同步阻塞调用，等待返回结果
doLow:最低优先doNomal:正常优先级doHigh:最优先执行
异步派发任务，不等待返回结果，返回任务句柄，通过该句柄可获取任务运行状态信息
doLowBackgrounddoBackgrounddoHighBackground
注意Task和doXXX区别，Task是一组job，派发后会分配到多个worker上并行执行并返回结果给调用方。
而doXXX的每个任务只会在一个worker上执行。
addTaskLowaddTaskaddTaskHighaddTaskLowBackground addTaskBackground addTaskHighBackground
cli.php代码如下：
<?php$client = new GearmanClient();$client->addServer(‘127.0.0.1‘, 4730);$client->setCompleteCallback(function($task) { echo $task->data(), PHP_EOL;});//分别添加不同优先级的Task$client->addTaskLow(‘sum‘, json_encode(array(100, 100)));$client->addTask(‘sum‘, json_encode(array(200, 200)));$client->addTaskHigh(‘sum‘, json_encode(array(300, 300)));$client->runTasks();worker.php代码如下：
<?php$worker = new GearmanWorker();$worker->addServer(‘127.0.0.1‘, 4730);$worker->addFunction(‘sum‘, function($job) { $data = http://www.mamicode.com/json_decode($job->workload(), true);>注意，为了实验效果，这里worker只需启动一个。
二、获取任务的状态
cli.php代码如下：
<?php$client = new GearmanClient();$client->addServer(‘127.0.0.1‘, 4730);//任务排队时的回调$client->setCreatedCallback(‘reverse_create‘);//有任务数据包时的回调$client->setDataCallback(‘reverse_data‘);//收集任务状态的回调$client->setStatusCallback(‘reverse_status‘);//任务完成时的回调$client->setCompleteCallback(‘reverse_complete‘);//任务失败时的回调$client->setFailCallback(‘reverse_fail‘);//分别添加不同优先级的Task$client->addTaskLow(‘reverse‘, ‘1234567‘);$client->addTask(‘reverse‘, ‘hello‘);$client->addTaskHigh(‘reverse‘, ‘world‘);$client->runTasks();function reverse_create($task) { echo ‘任务创建(‘, $task->jobHandle() , ‘): ‘, PHP_EOL;}function reverse_data($task) { echo ‘接收数据(‘, $task->jobHandle() , ‘): ‘, $task->data(), PHP_EOL;}function reverse_status($task) { //taskNumerator()获取任务完成情况的分子 //taskDenominator()获取任务完成情况的分母 echo ‘完成情况(‘, $task->jobHandle() , ‘): ‘, $task->taskNumerator(), ‘/‘, $task->taskDenominator(), PHP_EOL;}function reverse_complete($task) { echo ‘任务完成(‘, $task->jobHandle() , ‘): ‘, $task->data(), PHP_EOL;}function reverse_fail($task) { echo ‘任务失败(‘, $task->jobHandle() , ‘): ‘, PHP_EOL;}worker.php代码如下：
<?php$worker = new GearmanWorker();$worker->addServer(‘127.0.0.1‘, 4730);$worker->addFunction(‘reverse‘, function($job) { //workload()返回接收的数据 $data = http://www.mamicode.com/$job->workload();"worker: {$data} ({$dataSize}) \n"; $tmp = 0; $mid = $dataSize / 2; for($ix = 0; $ix < $mid; ++$ix) { $tmp = $data[$ix]; $data[$ix] = $data[$dataSize - $ix - 1]; $data[$dataSize - $ix - 1] = $tmp; //这里发送状态，会被client设置的回调reverse_status()接收到 //状态完成情况的分子与分母 $job->sendStatus($ix + 1, $mid + 1); //发送数据，被reverse_data()接收到 $job->sendData($data); sleep(1); } return $data;});while($worker->work());运行结果如下：
gearman中任务的优先级和返回状态
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。