The parallel\Events class

(0.9.0)

The Event Loop

The Event loop monitors the state of sets of futures and or channels (targets) in order to perform read (parallel\Future::value(), parallel\Channel::recv()) and write (parallel\Channel::send()) operations as the targets become available and the operations may be performed without blocking the event loop.

类摘要

final class parallel\Events implements Countable, Traversable {

/* Input */

public setInput(Input $input): void

/* Targets */

public addChannel(parallel\Channel $channel): void

public addFuture(string $name, parallel\Future $future): void

public remove(string $target): void

/* Behaviour */

public setBlocking(bool $blocking): void

public setTimeout(int $timeout): void

/* Polling */

public poll(): ?parallel\Events\Event

}

<?php
/**
Example showing the usage of events.

The documentation still is very thin, so I'm not sure, the example is the best solution. But it works.
*/
use parallel\{Channel,Runtime,Events,Events\Event};

$myThread = function(Channel $channel) {
$events = new Events();
$events->addChannel($channel);
//$events->setBlocking(false); //Uncomment to don't block on Events::poll()
$events->setTimeout(1000000); //Comment when not blocking

while(true)
    {
/*
        ...
        Your code.
        ...
        */

        //Read all available events
try
        {
$event = NULL;
            do
            {
$event = $events->poll(); //Returns non-null if there is an event
if($event && $event->source == 'myChannel')
                {
//It seems, the target gets deleted after returning an event,
                    //so add it again.
$events->addChannel($channel);
                    if($event->type == Event\Type::Read)
                    {
                        if(is_array($event->value) && count($event->value) > 0)
                        {
                            if($event->value['name'] == 'stop')
                            {
                                echo 'Stopping thread';
                                return; //Stop
}
                            else
                            {
                                echo 'Event: '.$event->value['name'].' => '.$event->value['value'].PHP_EOL;
                            }
                        }
                    }
                    else if($event->type == Event\Type::Close) return; //Stop
}
            }
            while($event);
        }
        catch(Events\Error\Timeout $ex)
        {
//Timeout
echo 'Timeout'.PHP_EOL;
        }
    }
};

class MyClass {
    private $runtime;
    private $future;
    private $channel;

    public function start() {
//Create runtime
$this->runtime = new Runtime();

//Create buffered channel.
        //Buffered channels don't block on Channel::send().
        //Note that target names need to be unique within the process.
$this->channel = Channel::make('myChannel', Channel::Infinite);

        global $myThread;
$this->future = $this->runtime->run($myThread, [$this->channel]);
    }

    public function stop() {
$this->channel->send(['name' => 'stop', 'value' => true]);

$this->future->value(); //Wait for thread to finish
$this->channel->close();
    }

    public function emit(string $name, $value)
    {
$this->channel->send(['name' => $name, 'value' => $value]);
    }
}

$a = new MyClass();
$a->start();

for($i = 0; $i < 5; $i++)
{
$a->emit('test', $i);
sleep(0.5);
}

sleep(2);

for($i = 5; $i < 10; $i++)
{
$a->emit('test', $i);
sleep(0.5);
}

$a->stop();
?>

down

gam6itko ¶

3 years ago

<?php

// this example shows how Events handle Future events

use parallel\{Events, Events\Event, Runtime};

$events = new Events();

$runtime = new Runtime();

//Read (type: 1)
$future = $runtime->run(
    static function (string $name) {
        return "Future#$name result";
    },
    ['Read']
);
$events->addFuture("Future#Read", $future);

//Cancel  (type: 4)
$future = $runtime->run(
    static function (string $name) {
        throw new \Exception("Exception#$name");
    },
    ['Cancel']
);
$events->addFuture("Future#Cancel", $future);

//Kill  (type: 5)
$future = $runtime->run(
    static function () {
sleep(100000);
    },
    []
);
$events->addFuture("Future#Kill", $future);
$future->cancel(); //kill it

//Error  (type: 6)
$future = $runtime->run(
    static function () {
$memoryEater = [];
$i = 0;
        while (++$i) {
$memoryEater[] = $i;
        }
    }
);
$events->addFuture("Future#Error", $future);

// reading events

/** @var Event $event */
foreach ($events as $i => $event) {
    echo str_pad('', 50, '=') . " EVENT_$i\n";
var_dump($event);
    echo "\n";
}

down

gam6itko ¶

3 years ago

<?php

// example below shows how to stop child thread from main thread

use parallel\{Channel, Events, Events\Event\Type, Runtime};

$fnThread = static function (Channel $channel) {
$events = new Events();
$events->addChannel($channel);
$events->setBlocking(false); // don't block on Events::poll()

while (true) {
        if ($event = $events->poll()) {
//It seems, the target gets deleted after returning an event, so add it again.
$events->addChannel($channel);

            if (Type::Read === $event->type) {
                echo "- received value: ".$event->value.PHP_EOL;
            } elseif (Type::Close === $event->type) {
                echo "- receiving close event".PHP_EOL;
                return "i'm done";
            }

        }
        echo "-\n";
usleep(500_000);
    }
};

// main thread
$runtime = new Runtime();
$channel = new Channel();
$future = $runtime->run($fnThread, [$channel]);

$channel->send('message1');
sleep(2);
$channel->send('message2');
sleep(2);

echo "closing channel\n";
$channel->close();
echo "future said: ".$future->value();
echo PHP_EOL;

＋添加备注

官方地址：https://www.php.net/manual/en/class.parallel-events.php

有任何技术问题请点击这里网站运营推广招聘

IT PHP 编程语言开发编程 Linux 科技 Elasticsearch HTML/CSS/XML 面试数据库网络 JAVA NoSQL C/C++ Golang 操作系统 Git 算法正则表达式 Redis 互联网 MySql 软件运维 JavaScript 国际架构设计 Mac OS Excel TCP/IP Windows Oracle Socket Vim VR MongoDB 运营 Python MemCache 商业硬件电子娱乐设计摄影 nginx WordPress 游戏 HTTP 团建数码电器 Docker

php7.3 使用 PDO_DM 扩展连接 DM8 中文乱码 PhpStorm中PHP注释的规范指南使用PHPWord将docx文件转换为html格式 docker-compose启动nginx与php-fpm laravel查看orm生成的sql PHPStorm ESC 会退出命令行 composer install参数 laravel orm中DB::insert方法导致内存泄漏的问题解决方法 php7 安装fileinfo扩展 adodb手册 ADORecordSet对象常用的php ADODB使用方法集锦利用php soap实现web service ADOConnection 公用函数 adodb连接mysql多个数据库的问题 mysql面试题 PHP注释规范 [PHP] inet_pton/inet_ntop IP地址转换函数 PHP7添加redis扩展 php上周一、本周一、下周一日期

略微加速

PHP官方手册 - 互联网笔记

The parallel\Events class

The Event Loop

类摘要

目录

发现了问题？

用户贡献的备注 3 notes