Идентификатор потока в PHP: методы и примеры

Расширенные примеры использования идентификатора потока

Пример 1 несколько открытых потоков и их ID

Демонстрация того, как разные потоки получают уникальные идентификаторы.

<?php
$f1 = fopen('/tmp/file1.txt', 'w');
$f2 = fopen('/tmp/file2.txt', 'w');
$s1 = stream_socket_server('tcp://127.0.0.1:0', $errno, $errstr);

$ids = [
    'file1' => stream_get_id($f1),
    'file2' => stream_get_id($f2),
    'server' => stream_get_id($s1),
];

print_r($ids);

fclose($f1); fclose($f2); fclose($s1);
?>

Array
(
    [file1] => 4
    [file2] => 5
    [server] => 6
)

Пример 2 использование stream_select и идентификация потоков по ID

В цикле обработки событий можно отслеживать активные потоки по их идентификаторам.

<?php
$server = stream_socket_server('tcp://127.0.0.1:0', $errno, $errstr);
$clients = [];

// добавляем сервер в массив для чтения
$read = [$server];

while (true) {
    $write = $except = null;
    if (stream_select($read, $write, $except, 0) > 0) {
        foreach ($read as $stream) {
            $id = stream_get_id($stream);
            echo "Готов к чтению поток ID: $id\n";
            // обработка...
        }
    }
    // лимит на демонстрацию
    break;
}
fclose($server);
?>

Готов к чтению поток ID: 5

Пример 3 сравнение потоков через ID

Проверка, ссылаются ли две переменные на один и тот же поток.

<?php
$f = fopen('/tmp/test.txt', 'r');
$g = $f; // присваиваем ссылку
$h = fopen('/tmp/test.txt', 'r'); // открываем отдельно

$idF = stream_get_id($f);
$idG = stream_get_id($g);
$idH = stream_get_id($h);

echo "f: $idF, g: $idG, h: $idH\n";
echo "f === g: " . ($idF === $idG ? 'true' : 'false') . "\n";
echo "f === h: " . ($idF === $idH ? 'true' : 'false') . "\n";

fclose($f); fclose($h);
?>

f: 4, g: 4, h: 5
f === g: true
f === h: false

Пример 4 пользовательский stream wrapper и его ID

Создание простого обёртки потока и получение идентификатора объекта.

<?php
class MyStream {
    private $data;
    public function stream_open($path, $mode, $options, &$opened_path) {
        $this->data = 'test';
        return true;
    }
    public function stream_read($count) { return substr($this->data, 0, $count); }
    public function stream_write($data) { $this->data .= $data; return strlen($data); }
    public function stream_eof() { return empty($this->data); }
}

stream_wrapper_register('my', MyStream::class);
$s = fopen('my://test', 'r+');
echo "ID пользовательского потока: " . stream_get_id($s) . "\n";
fclose($s);
?>

ID пользовательского потока: 3

Пример 5 получение ID сокета сервера и его клиентов

Демонстрация идентификации серверного и клиентских сокетов в простом TCP сервере.

<?php
$server = stream_socket_server('tcp://127.0.0.1:0', $errno, $errstr);
echo "Сервер ID: " . stream_get_id($server) . "\n";

// имитируем подключение клиента
$client = stream_socket_client(stream_socket_get_name($server, false));
$accepted = stream_socket_accept($server, 0);
echo "Принятый клиент ID: " . stream_get_id($accepted) . "\n";
echo "Клиент (исходный) ID: " . stream_get_id($client) . "\n";

fclose($client); fclose($accepted); fclose($server);
?>

Сервер ID: 4
Принятый клиент ID: 5
Клиент (исходный) ID: 6