gearman中任务的优先级和返回状态的介绍_F11 - 专业站长和开发者的学习网站

分享到

gearman中任务的优先级和返回状态的介绍

php 来源：互联网搜集作者：秩名发布时间：2020-02-29 19:47:00 人浏览

摘要

gearman中任务的优先级和返回状态一、任务的优先级同步阻塞调用，等待返回结果 ? 1 2 3 doLow:最低优先 doNomal:正常优先级 doHigh:最优先执行异步派发任务，不等待返回结果，返回任务句柄，通过该句柄可获取任务运行状态信息 ? 1 2 3 doLowBackground do

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_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 = $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());

运行结果如下：

您可能感兴趣的文章 :

原文链接 : https://www.cnblogs.com/jkko123/p/6537522.html

Tag : gearman(4)

PHP数据加密方式的总结

首先我们来了解一下为什么要加密？在网络通信的过程中攻击者可以伪造请求和返回，从而达到不可告人的目的。如下图所示：数据加密之
PHP四种统计在线人数方式介绍

1 用表统计方式用数据表统计在线人数，这种方式只能用在并发量不大的情况下。首先我们先新建表：user_login 编辑 user_login 表模拟用户登
PHP获取系统毫秒数时间方法

前言 php中获取时间方法是date()，在php中获取时间戳方法有time()、strtotime()； date()：date(format, timestamp)，format为格式、timestamp为时间戳（可选
PHP中的DI依赖注入的详细介绍

什么是 DI / 依赖注入依赖注入DI 其实本质上是指对类的依赖通过构造器完成自动注入通俗来说，就是你当前操作一个类，但是这个类的某
PHP8.1 Fiber交叉执行多任务（附代码）

拿平时大家写的 for 循环举例。像 go 你可以写两个go每个里面各写一个循环同时输入，你可以看到输出是交替。在过去的php版本中，如果只开
PHP8.0的编译安装与使用的介绍

安装与配置本次使用的操作系统Ubuntu 18.04.4 LTS 安装 1.准备必要库 1 2 apt-get install -y autoconf libxml2-dev libsqlite3-dev \ libcurl4-openssl-dev libssl-dev l
Mac如何编译PHP 8.0 到MxSrvs工具

开始准备工作下载 PHP 8.0 PHP 官方下载 https://www.php.net/downloads.php 进入到 MxSrvs 的主程序路径下的/Applications/MxSrvs/bin，根据 Mxsrvs 的命名规则，
PHP8 中的 JIT的详细介绍

PHP 8 的 JIT（Just In Time）编译器将作为扩展集成到 php 中 Opcache 扩展用于运行时将某些操作码直接转换为从 cpu 指令。这意味着使用JIT后，
PHP8.2不再支持字符串中用${}插入变量了

PHP 社区 4 月底通过了一项只有一张反对票的提案，提案内容是在即将发布的 PHP 8.2 中，不再支持使用 ${} 在字符串中插入变量的语法（标记
PHP8.2两个新的强类型：null和false的详细介绍

PHP 从 7.0 开始不断地在完善强类型，我们可以给方法参数、返回值、类属性等声明类型。强类型可以让代码更加健壮，易于维护，可读性增