文档章节

Task_worker 简单流程

304158
 304158
发布于 2017/06/28 11:11
字数 577
阅读 13
收藏 0

1.Task_worker_num 

配置task进程的数量,配置此参数后将会启用task功能。所以swoole_server务必要注册onTask/onFinish2个事件回调函数。如果没有注册,服务器程序将无法启动。

function onTask(swoole_server $serv, int $task_id, int $src_worker_id, mixed $data);
/*

    $task_id是任务ID,由swoole扩展内自动生成,
    用于区分不同的任务。$task_id和$src_worker_id组合起来才是全局唯的,
    不同的worker进程投递的任务ID可能会有相同
    $src_worker_id来自于哪个worker进程
    $data 是任务的内容

*/
void onFinish(swoole_server $serv, int $task_id, string $data)

/*
    $task_id是任务的ID
    $data是任务处理的结果内容
task进程会通过swoole_server->finish()方法将任务处理的结果发送给worker进程


*/

例如

Task_worker_num  = 100

Task 任务池中,能够创建100个Task 处理任务.

可以制定要给投递给哪个task进程,传入ID即可,范围是0 - (serv->task_worker_num -1)

Task异步的进程

TaskWaitMulti并发多个Task进程

$tasks[] = mt_rand(1000, 9999); //任务1
$tasks[] = mt_rand(1000, 9999); //任务2
$tasks[] = mt_rand(1000, 9999); //任务3
var_dump($tasks);

//等待所有Task结果返回,超时为10s
$results = $serv->taskWaitMulti($tasks, 10.0);

if (!isset($results[0])) {
    echo "任务1执行超时了\n";
}
if (isset($results[1])) {
    echo "任务2的执行结果为{$results[1]}\n";
}
if (isset($results[2])) {
    echo "任务3的执行结果为{$results[2]}\n";
}

Taskwait 阻塞的进程

<?php


    $serv = new swoole_server("127.0.0.1", 9501);
    $serv->set(array(
        'worker_num' => 4,
        'daemonize' => false,
        'dispatch_mode'=>2,
        'task_worker_num'=>100,

    ));
    //启动服务器
    $serv->on('start',function ($serv) {  //服务器启动回调
            echo "+++++++启动了一个SWOOLE++++++++";

    });
    //服务器启动的Worker进程
    $serv->on('WorkerStart',function ($serv,$worker_id){
        //echo $worker_id."Worker\n";

    });

    $serv->on('connect', function ($serv, $fd){  // 客户端链接服务器回调
        echo "\n====================================\n";
        foreach($serv->connections as $k=>$v)
        {
            var_dump($k,$v);
        }
        echo "====================================\n";


    });

    $serv->on('receive', function ($serv, $fd, $from_id, $data) {//接收到来自客户端信息的回调
        $serv->tick(10000, function() use ($serv, $fd) {

           /* $serv->task("taskcallback", -1, function (swoole_server $serv, $task_id, $data) use($fd) {
                var_dump($task_id, $data);
                $serv->send($fd, $serv->worker_id."task");
            });*/
           $ob = $serv->task("进行一次异步");
            $serv->send($fd, $serv->worker_id."task");

        });

    });

    $serv->on('close', function ($serv, $fd) {//关闭于客户端的链接回调
        echo "ID=".$fd.":一个链接关闭了.\n";
    });



    //task 回调
    $serv->on('task',function ($serv,$task_id,$src_worker_id,$data){
        echo "创建了一个task\n";
        $serv->finish($data);
    });
    //task 任务完成回调
    $serv->on('finish',function ($serv,$task_id,$data){
        echo $data."->>>>>由finish完成传递\n";
    });

        $serv->start();//运行服务

 

© 著作权归作者所有

共有 人打赏支持
304158
粉丝 1
博文 105
码字总数 30016
作品 0
大兴安岭
私信 提问
spark运行模式

Local模式 运行Spark最简单的方法是通过Local模式(即伪分布式模式)。 运行命令为:./bin/run-example org.apache.spark.examples.SparkPi local 基于standalone的Spark架构与作业执行流程 ...

张欢19933
2016/02/18
88
1
Spark Job 详细执行流程(一)

本文以Spark 1.6 Standalone模式为例,介绍用户提交Spark Job后的Job的执行流程。大体流程如下图所示 Spark集群运行架构 用户提交Job后会生成SparkContext对象,SparkContext向Cluster Manag...

imarch1
2016/03/23
0
0
ThreadPoolExecutor源码解析(二)

1.ThreadPoolExcuter运行实例   首先我们先看如何新建一个ThreadPoolExecutor去运行线程。然后深入到源码中去看ThreadPoolExecutor里面使如何运作的。 2.ThreadPoolExecute.execute方法  ...

终日而思一
11/19
0
0
Java爬虫框架

一、 模块 1. Scheduler Scheduler负责启动爬虫,停止爬虫,监控爬虫的状态。 Scheduler在调度爬虫时,借助于Quartz,设置爬虫在某个时刻启动。同一个名字的爬虫是stateful的。 Task:初始化...

超人学院
2016/07/26
87
0
Spark(二):简单了解Spark架构与运行逻辑

一:Spark的架构。 1. Driver:运行Application的main()函数并且创建SparkContext。 2. Client:用户提交作业的客户端。 3. Worker:集群中任何可以运行 Application 代码的节点,运行一个或...

牧羊人Berg
2016/06/02
219
0

没有更多内容

加载失败,请刷新页面

加载更多

多线程的实现方式

多线程是指 一个程序运行时,产生或使用了不止一个线程。 线程的生命周期是怎么样的,下面这张图我们可以看出些端倪: 这章我们主要讨论多线程实现的方式,基础知识部分我们可以下来再恶补。...

搬砖大侠
16分钟前
0
0
新人千万不要在 Windows 上使用 Ruby on Rails

标题:新人千万不要在 Windows 上使用 Ruby on Rails 副标题:鼓励新人在 Linux 和 Mac 上使用 Ruby on Rails ! 原则:要走寻常路,不要学美特斯邦伟! "在 Windows上 使用 Ruby on Rails "是...

Jason909
24分钟前
0
0
day177-2018-12-14-英语流利阅读-待学习

艾滋病的治愈方法是否触手可及? Daniel 2018-12-14 1.今日导读 几十年来,艾滋病一直是世界上最难对付的“超级绝症”之一,从人类历史上第一次诊断出艾滋病病例的 20 世纪 80 年代早期到 20...

飞鱼说编程
50分钟前
7
0
java 合成两张图片或图片与二维码

java中偶尔会出现需要将一张小图片嵌入大图中或带二维码的海报图片,那么本文就是奔着这个目的来的,直接上腊肉! zxing是生成1D和2D条形或二维码的工具类库,java图形库Graphics2D进行图片的...

貔貅叔
54分钟前
4
0
80后阿里P10,“关老板”如何带着MaxCompute一路升级?

我是个幸运的人。虽然幸运不能被复制,但是眼光和努力可以。 关涛/关老板,80后的阿里P10,阿里巴巴通用计算平台负责人,阿里巴巴计算平台研究员。12年职场人生,微软和阿里的选择。 关涛的花...

阿里云官方博客
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部