gearman中任务的优先级和返回状态实例分析
网络编程 2021-07-04 23:05www.168986.cn编程入门
这篇文章主要介绍了gearman中任务的优先级和返回状态,结合实例形式分析了gearman任务的优先级以及获取返回状态相关操作技巧,需要的朋友可以参考下
本文实例讲述了gearman中任务的优先级和返回状态。分享给大家供大家参考,具体如下:
gearman中任务的优先级和返回状态
一、任务的优先级
同步阻塞调用,等待返回结果
doLow:最低优先 doNomal:正常优先级 doHigh:最优先执行
异步派发任务,不等待返回结果,返回任务句柄,通过该句柄可获取任务运行状态信息
doLowBackground doBackground doHighBackground
注意Task和doXXX区别,Task是一组job,派发后会分配到多个worker上并行执行并返回结果给调用方。
而doXXX的每个任务只会在一个worker上执行。
addTaskLow addTask addTaskHigh addTaskLowBackground 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 = json_decode($job->workload(), true); $ret = $data[0] + $data[1]; echo $ret, PHP_EOL; sleep(1); return $ret; }); while($worker->work());
注意,为了实验效果,这里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_plete'); //任务失败时的回调 $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_plete($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 = $job->workload(); //workloadSize()返回接收数据的字节大小 $dataSize = $job->workloadSize(); echo "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());
运行结果如下:
更多关于PHP相关内容感兴趣的读者可查看本站专题:《》、《》、《》、《》、《》、《》及《》
希望本文所述对大家PHP程序设计有所帮助。
编程语言
- 机械手焊接机器人编程 机械手焊接设备编程
- vb数据库编程实例,vb做数据库
- tiobe世界编程语言排行榜,全球编程语言排行
- 成都java编程培训 成都it编程培训中心
- 编程基础培训,编程基础知识培训
- flash游戏编程基础教程,flash游戏开发教程
- 不会英语能学编程吗 不会英语可以学程序员吗
- 爱心代码编程C语言 爱心代码编程c语言公式
- c语言编程学习入门 c语言编程快速入门
- 西门子plc编程培训 西门子plc编程培训班
- 哪里可以学编程 台州哪里可以学编程
- 少儿编程哪个好 少儿编程哪个品牌好
- 编程是什么意思,图形编程是什么意思
- c语言编程软件下载,c语言编程软件在哪下载
- java编程软件下载,java编程下载手机版
- ug编程培训学校,ug编程培训教程