parallel\Channel::__construct

(1.1.0)

parallel\Channel::__construct — Конструктор класса Channel

Описание

public parallel\Channel::__construct()

Создаёт анонимный небуферизованный канал

public parallel\Channel::__construct(int $capacity)

Создаёт анонимный буферизованный канал с заданной ёмкостью.

Список параметров

capacity: Может быть Channel::Infinite или положительным целым числом.

Нашли ошибку?

Инструкция • Исправление • Сообщение об ошибке

＋Добавить

Примечания пользователей 2 notes

down

abolfazl dot ziaratban at gmail dot com ¶

3 years ago

$capacity is count of stack in buffer.

for example :

<?php
use parallel\{Channel,Runtime};

$test = function($ch){
    var_dump($ch->Recv());
    var_dump($ch->Recv());
    var_dump($ch->Recv());
    echo 'Sleep'.PHP_EOL;
    sleep(3);
    echo 'Call Recv()'.PHP_EOL;
    var_dump($ch->Recv());
};

$t1 = new Runtime();
$ch = new Channel(3); //buffered channel 
$ch->Send('abc1');
$ch->Send('abc2');
$ch->Send('abc3');
$t1->Run($test,[$ch]);
sleep(1);
echo 'Wait for Recv()...'.PHP_EOL;
$ch->Send('abc4'); #php waits for only one stack of channel to be empty(by Recv() method)
?>

result:
string(4) "abc1"
string(4) "abc2"
string(4) "abc3"
Sleep
Wait for Recv()...
Call Recv()
string(4) "abc4"

down

frame86 at live dot com ¶

4 years ago

Please note $capacity unit is 1 MiB each, not bytes

＋Добавить