PHP实现简单的协程任务调度demo示例
时间:2022-07-27
本文章向大家介绍PHP实现简单的协程任务调度demo示例,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
本文实例讲述了PHP实现简单的协程任务调度。分享给大家供大家参考,具体如下:
<?php
class Task
{
protected $taskId;
protected $coroutine;
protected $sendValue = null;
protected $beforeFirstYield = true;
public function __construct($taskId, Generator $coroutine)
{
$this- taskId = $taskId;
$this- coroutine = $coroutine;
}
public function getTaskId()
{
return $this- taskId;
}
public function setSendValue($sendValue)
{
$this- sendValue = $sendValue;
}
public function run()
{
if ($this- beforeFirstYield) {
$this- beforeFirstYield = false;
return $this- coroutine- current();
} else {
$retval = $this- coroutine- send($this- sendValue);
$this- sendValue = null;
return $retval;
}
}
public function isFinished()
{
return !$this- coroutine- valid();
}
}
class Scheduler
{
protected $maxTaskId = 0;
protected $taskMap = []; // taskId = task
protected $taskQueue;
public function __construct()
{
$this- taskQueue = new SplQueue();
}
public function newTask(Generator $coroutine)
{
$tid = ++$this- maxTaskId;
$task = new Task($tid, $coroutine);
$this- taskMap[$tid] = $task;
$this- schedule($task);
return $tid;
}
public function schedule(Task $task)
{
$this- taskQueue- enqueue($task);
}
public function run()
{
while (!$this- taskQueue- isEmpty()) {
$task = $this- taskQueue- dequeue();
$task- run();
if ($task- isFinished()) {
unset($this- taskMap[$task- getTaskId()]);
} else {
$this- schedule($task);
}
}
}
}
function task1()
{
for ($i = 1; $i <= 10; ++$i) {
echo "This is task 1 iteration $i.n";
sleep(1);
yield;
}
}
function task2()
{
for ($i = 1; $i <= 10; ++$i) {
echo "This is task 2 iteration $i.n";
sleep(1);
yield;
}
}
$scheduler = new Scheduler;
$scheduler- newTask(task1());
$scheduler- newTask(task2());
$scheduler- run();
运行结果:
This is task 1 iteration 1. This is task 1 iteration 2. This is task 1 iteration 3. This is task 1 iteration 4. This is task 1 iteration 5. This is task 1 iteration 6. This is task 1 iteration 7. This is task 1 iteration 8. This is task 1 iteration 9. This is task 1 iteration 10.
更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
- php概述
- php教程
- php环境搭建
- PHP书写格式
- php变量
- php常量
- PHP注释
- php数组
- php字符串 string
- PHP整型 integer
- PHP浮点型 float
- php布尔型
- php数据类型之数组
- php数据类型之对象
- php数据类型之null
- php数据类型之间的转换
- php运算符
- php表达式
- PHP循环控制
- PHP流程控制
- php函数
- php全局变量
- PHP魔术变量
- php命名空间
- php 日期
- PHP包含文件
- php文件
- PHP 文件上传
- php Cookies
- php Sessions
- php email
- php安全email
- php错误处理
- PHP异常处理
- php过滤器
- PHP 高级过滤器
- php json
- php 表单
- PHP MySQL 简介
- PHP 连接 MySQL
- php创建数据库
- php 创建表
- php mysq 插入数据
- PHP MySQL 插入多条数据
- PHP MySQL 预处理语句
- php mysql 读取数据
- php mysql where
- PHP MySQL Order By
- PHP MySQL Update
- PHP MySQL Delete
- php ODBC
- Synchronized简述
- PythonforResearch | 2_数据处理
- 程序员过关斩将--Http请求中如何保持状态?
- 如何有效恢复误删的HDFS文件
- 别再用OFFSET和LIMIT分页了
- 别再用大小比较时间了
- Redis快速入门
- 捉虫记:Unexpected end of JSON input while parsing
- 重新思考日志:业务系统竟然是一个大数据库?
- 测试面试题集-Linux常用命令
- 「真香警告」鱼头手摸手教你在小程序里用composition-api
- 【技术文】SSL握手中的几个密码
- 分布式监控系统SkyWalking
- 文献笔记二十九:银合欢(Leucaena trichandra)线粒体基因组
- Docker Swarm群集配置实战——第一战