Клас parallel\Channel

(0.9.0)

Небуферизовані канали

Небуферизований канал блокуватиметься під час дзвінків parallel\Channel::send() до тих пір, поки не з'явиться одержувач, і блокуватись при викликах parallel\Channel::recv() доти, доки з'явиться відправник. Це означає, що небуферизований канал - це спосіб обміну даними між завданнями, а й простий метод синхронізації.

Небуферизований канал - це найшвидший спосіб обміну даними між завданнями, що вимагає найменшої кількості копіювання.

Буферизовані канали

Буферизований канал не блокуватиметься під час дзвінків parallel\Channel::send() до заповнення буфера, а дзвінки parallel\Channel::recv() блокуватимуться до тих пір, поки в буфері є дані.

Замикання поверх каналів

Потужна особливість паралельних каналів у тому, що дозволяють обмінюватися замиканнями між завданнями (і середовищами виконання).

Коли замикання відправляється по каналу, воно буферизується, не змінює буферизацію каналу, що передає замикання, але воно впливає на статичну область видимості всередині замикання: одне і те ж замикання, відправлене в різні середовища виконання або в те саме середовище виконання, не ділитися своєю статичною областю.

Це означає, що кожного разу, коли виконується замикання, яке було передане каналом, статичний стан буде таким, яким воно було при буферизації замикання.

Анонімні канали

Конструктор анонімного каналу дозволяє програмісту уникати присвоєння імен кожному каналу: parallel генерує унікальне ім'я анонімних каналів.

Огляд класів

    
     
      final
      class parallel\Channel
     
     {


    /* Анонимный конструктор */
    
   public __construct()
public __construct(int $capacity)


    /* Доступ */
    public make(string $name): Channel
public make(string $name, int $capacity): Channel
public open(string $name): Channel


    /* Совместное использование */
    public recv(): mixed
public send(mixed $value): void


    /* Закрытие */
    public close(): void


    /* Константа для бесконечной буферизации */
    
     const
      Infinite;


   }

Зміст

• parallel\Channel::__construct - Конструктор класу Channel
• parallel\Channel::make - Доступ
• parallel\Channel::open - Доступ
• parallel\Channel::recv - Спільне використання
• parallel\Channel::send - Спільне використання
• parallel\Channel::close - Закриття