masakielastic

<?php
/**
 * Fiber協調スケジューラ（sleep + readable + writable）
 */

final class Scheduler
{
    /** @var SplQueue<array{0:Fiber,1:mixed}> */
    private SplQueue $ready;

masakielastic

<?php
/**
 * Fiber協調スケジューラ（sleep + readable + writable）
 * - await(['sleep', seconds])     -> resume(seconds)
 * - await(['readable', stream])   -> resume(stream)
 * - await(['writable', stream])   -> resume(stream)
 */

final class Scheduler
{

masakielastic

<?php
/**
 * Fiber協調スケジューラ（sleep + stream_select readable 対応）
 * - await(['sleep', seconds]) → 指定時刻に resume(value)
 * - await(['readable', stream]) → stream が readable になったら resume(stream)
 */

final class Scheduler
{
    /** @var SplQueue<array{0:Fiber,1:mixed}> */

masakielastic

<?php
/**
 * 超ミニ協調スケジューラ
 * - newTask(fn) でタスク（Fiber）登録
 * - sleep(seconds) で「指定時刻まで待つ」をFiber側から要求
 * - run() で実行（単一スレッド、協調のみ）
 */

final class Scheduler
{

masakielastic

リクエストとレスポンスの扱い | PHP 拡張 ext-php-rs

src/main.rs

[package]
name = "php_warp_server"
version = "0.1.0"
edition = "2021"

masakielastic

warp v0.4 でシングルスレッド

シングルスレッド

Cargo.toml

[package]
name = "warp-project"

masakielastic

poll/await 風のコード | PHP 拡張 ext-php-rs

Cargo.toml

[package]
name = "async-project"
version = "0.1.0"
edition = "2024"

masakielastic

クロージャ | PHP 拡張 ext-php-rs

Cargo.toml

[package]
name = "closure-project"
version = "0.1.0"
edition = "2024"

masakielastic

リクエストとレスポンスを扱うハンドラを登録する | PHP 拡張 ext-php-rs

ソースコード

Cargo.toml

[package]

masakielastic

warp v0.4 で TLS なしの HTTP サーバーその2・JSON レスポンス | PHP 拡張、ext-php-rs

コード

Cargo.toml