【入門編】Fiberを用いたバックプレッシャー（流量制御）の実装パターン：システム過負荷の回避 – PHPコア・内部エンジンと高速化・並行処理の極意解析バイブル

こんにちは。普段からNode.jsやGo、あるいはJavaなどの他言語で非同期処理やストリーム制御をバリバリ書いてきたあなたなら、PHPの「同期的な世界観」から一歩踏み出したとき、ある種の物足りなさと、同時に「どこまでPHPのエンジンを追い込めるか」という知的な興奮を覚えていることでしょう。

他のモダン言語では当たり前のように使われる非同期・並行処理のプリミティブですが、PHP 8.1で導入された Fiber（ファイバー） によって、PHPの実行モデルは劇的な進化を遂げました。

今回は、そのFiberを武器にして、実システムの命綱となる「バックプレッシャー（流量制御）」をどう実装し、PHPの内部エンジンがそれをどう処理しているのかを紐解いていきます。

「ここを理解すれば、PHPの裏側が綺麗に見えますよ」。さあ、一緒に低レイヤの扉を開けてみましょう。

—

1. なぜPHPに「バックプレッシャー」が必要なのか？

他言語の高パフォーマンスな環境（GoのGoroutineやNode.jsのStreamsなど）では、上流からのリクエストやデータ生産スピードが、下流（DB、外部API、ディスクI/Oなど）の消費スピードを上回ったとき、システムが自壊しないように流量を絞るメカニズムが標準で備わっています。これがバックプレッシャー（逆圧）です。

では、PHP（特にFPM環境）はどうでしょう？
「PHPは1リクエスト1プロセス（またはスレッド）で動くから、関係ないよ」なんて思っていませんか？

もしあなたが、ひとつのリクエストの中で数千件の外部APIを非同期並行で叩くバッチ処理や、WebSocketサーバーのような常駐型PHPアプリケーション（SwooleやReactPHPなどの基盤）を構築しているなら話は別です。下流のキャパシティを無視してFiberを乱立させれば、瞬時にメモリ（Zend Engineのヒープ）が枯渇し、OOM Killerにプロセスを屠られるか、外部サービスをDDOS攻撃しているかのような悲惨な状況に陥ります。

PHPのFiberは「協調的マルチタスキング（Cooperative Multitasking）」を実現する道具です。OSのスレッドのように勝手にコンテキストスイッチしてくれるわけではありません。「あなたが手動でサスペンド（中断）させ、あなたが流量をコントロールしなければならない」。だからこそ、アーキテクトの腕の見せ所なのです。

—

2. 内部構造の理解：FiberとZend VMのコールスタック

バックプレッシャーを実装する前に、PHPのコアがFiberをどう扱っているのか、その裏側を少しだけ覗いておきましょう。

通常、PHPの関数呼び出しやメソッド実行は、Zend VM上の実行スタック（zend_execute_data）に積み上げられていきます。通常の関数なら、returnした瞬間にそのスタックフレームは破棄されますよね。

しかし、`Fiber::suspend()` がコールされると、PHPエンジンは何をするでしょうか？
エンジンは、現在のコールスタック全体（ローカル変数や実行ポインタを含む）をヒープメモリ上に退避させます。 そして、制御権を親のスコープ（イベントループやスケジューラ）に返します。

つまり、Fiberを生成しすぎるということは、「ヒープ上に途方もない数のコールスタックの残骸をばらまく」と同義なのです。これがメモリを圧迫し、ガベージコレクションの負荷を高める原因になります。だからこそ、アクティブなFiberの数、すなわち「流れるデータの量」を制御するバックプレッシャーが絶対に必要なのです。

—

3. 実装パターン：イベントループと連携する流量制御付きFiberプール

それでは、実際にバックプレッシャーを考慮したFiberの制御機構をPHPで書いてみましょう。
今回は、外部へのリクエストや重い処理を想定し、「同時に実行してよいFiberの最大数（Concurrency Limit）」を厳格に管理するスケジューラを実装します。

バックプレッシャー（流量制御）を伴うFiberタスクマネージャー

/
class BackpressureTaskScheduler
{
/ @var \SplQueue 実行待ちのタスクキュー（FIFO） /
private \SplQueue $queue;

/ @var array 現在実行中のFiberリスト /
private array $activeFibers = [];

/ @var int 同時実行の最大数（これがバッファの閾値となる） /
private int $maxConcurrency;

private int $nextId = 0;

public function __construct(int $maxConcurrency)
{
$this->queue = new \SplQueue();
$this->maxConcurrency = $maxConcurrency;
}

新しいタスク（クロージャ）をキューに投入する

/
public function push(callable $taskCreator): void
{
$fiber = new Fiber(function () use ($taskCreator) {
// タスクを実行し、その結果を返す
$taskCreator();
});

if (count($this->activeFibers) < $this->maxConcurrency) {
// まだ同時実行数に余裕があれば即座に起動
$this->startFiber($fiber);
} else {
// 満杯の場合はキューに積む（これがバックプレッシャーの「待機状態」）
echo “[Backpressure] 同時実行数が上限({$this->maxConcurrency})に達しました。タスクをキューに退避します。\n”;
$this->queue->enqueue($fiber);
}
}

Fiberを起動し、アクティブリストに登録する

/
private function startFiber(Fiber $fiber): void
{
$id = $this->nextId++;
$this->activeFibers[$id] = $fiber;

try {
// 初回スタート
$fiber->start();
} catch (\Throwable $e) {
echo “[Error] Fiber内で例外が発生しました: ” . $e->getMessage() . “\n”;
unset($this->activeFibers[$id]);
$this->dequeueNext();
return;
}

// Fiberがサスペンドしたか、終了したかをチェック
if ($fiber->isTerminated()) {
// 正常終了した場合
unset($this->activeFibers[$id]);
// 次の待機タスクを呼び起こす
$this->dequeueNext();
}
}

キューから次のタスクを取り出し、空いたスロットで実行する

/
private function dequeueNext(): void
{
if ($this->queue->isEmpty()) {
return;
}

// キューから次のFiberを取り出す
$nextFiber = $this->queue->dequeue();
echo “[Backpressure] キューから次のタスクをウェイクアップします。残りの待機数: {$this->queue->count()}\n”;

$this->startFiber($nextFiber);
}

全てのタスクが消化されるまでイベントループを回す

/
public function run(): void
{
// 実際のプロダクションではここでイベントループ（ReactPHPやAmpなど）と連携しますが、
// 今回はシンプルにアクティブなFiberがゼロになるまで同期的に待機させます。
while (!empty($this->activeFibers) || !$this->queue->isEmpty()) {
// ここでは簡易的にCPUを空転させないためのディレイやイベント待機を想定
usleep(10000); // 10ms
}
}
}

// ==========================================
// 実行シミュレーション
// ==========================================

$scheduler = new BackpressureTaskScheduler(maxConcurrency: 3);

// 下流の処理能力（最大同時3つ）を超える10個のタスクを投入してみる
for ($i = 1; $i <= 10; $i++) { $taskId = $i; $scheduler->push(function () use ($taskId) {
echo “–> タスク #{$taskId} が処理を開始しました。\n”;

// 外部APIコールや重いDBクエリの模倣（非同期的に数秒かかる想定）
// Fiber内であれば、ここで suspend を呼んで他のタスクに処理を譲ることも可能です。
usleep(rand(100000, 300000)); // 100ms〜300msの処理時間

echo “<-- タスク #{$taskId} が処理を完了しました。\n"; }); } // スケジューラの実行開始 $scheduler->run();

—

4. このコードが教えてくれる「PHPの本質」

上記のコードを眺めてみてください。ここには、PHPで非同期・並行処理を設計する上での極意が詰まっています。

1. `maxConcurrency` によるハードリミット
下流のシステム（例えばRDBのコネクションプール数や、外部APIのレートリミット）の許容量に合わせて最大値を設定することで、予期せぬ負荷スパイクからシステムを守ることができます。
2. `\SplQueue` による効率的なメモリ管理
配列の `array_shift` を使うとPHPの内部ではインデックスの再計算が発生し、余計なCPUサイクルを消費しますが、SPLの `\SplQueue` は双方向リスト（Doubly Linked List）ベースで実装されているため、O(1)の計算量で高速にキューの出し入れができます。低レイヤを知るエンジニアなら、こうした細かいデータ構造の選択が全体のパフォーマンスを左右することを知っているはずです。
3. Zendヒープへの優しさ
一度に数千のFiberを生成してメモリを破裂させる代わりに、「流れるプール」のように一定数だけをアクティブにし、残りはキューで静かに待たせる。これにより、Zend VMのメモリフットプリントを最小限に抑えることができます。

—

5. さらなる高みへ：リアクティブ・プログラミングとの融合

今回はシンプルに `usleep` とポーリングで説明しましたが、実プロダクションのWebアプリケーション（Swoole, RoadRunner, あるいはReactPHPベースのアーキテクチャ）では、このキューとFiberのサスペンドをイベントループ（Epoll / Kqueue）と美しく結合させます。

例えば、ネットワークI/Oを待つ必要があるとき、Fiber側で `Fiber::suspend()` を呼び、イベントループに「このソケットにデータが来たら、このFiberを再開（resume）してくれ」と登録するのです。これにより、CPUを100%使い潰すような無駄なビジーループ（空回り）を完全に排除し、極限までスケーラブルなPHPアプリケーションが完成します。

「PHPは遅い、非同期が苦手だ」という神話は、もはや過去のものです。PHP 8以降のエンジン内部構造とFiberの仕様を正しく掌握すれば、他のどのモダン言語にも引けを取らない高効率なバックプレッシャー制御システムを構築できます。

ぜひ、あなたの次のプロダクトでこの設計を取り入れ、静かに、そして圧倒的なパフォーマンスで動くPHPの裏側を楽しんでみてください。