Public Member Functions
	__construct (string $moduleName, callable $loader, int $timeout=5000)
	getModuleName ()
	getResult ()
	isReady ()
	isSuspended ()
	isTerminated ()
	wait (int $timeout=5000)

Private Attributes
	$fiber
	$initialized = false
	$moduleName
	$result = null
	$timeout

Detailed Description

Internal: Single fiber module wrapper Manages lifecycle of a single module's fiber

Definition at line 178 of file class.fibermoduleloader.php.

Constructor & Destructor Documentation

◆ __construct()

__construct	(	string	$moduleName,
		callable	$loader,
		int	$timeout = 5000 )

Definition at line 186 of file class.fibermoduleloader.php.

    {
        $this->moduleName = $moduleName;
        $this->timeout = $timeout;
 
        // Create fiber (PHP 8.1+)
        $this->fiber = new Fiber(function() use ($loader) {
            try {
                $this->result = call_user_func($loader);
                $this->initialized = true;
            } catch (Throwable $e) {
                Log::error('Fiber error in ' . $this->moduleName . ': ' . $e->getMessage());
                $this->initialized = true; // Mark as done even on error
            }
        });
 
        // Start the fiber (begins execution until first yield)
        try {
            $this->fiber->start();
        } catch (Throwable $e) {
            Log::error('Failed to start fiber for ' . $this->moduleName . ': ' . $e->getMessage());
            $this->initialized = true;
        }
    }

References $moduleName, $timeout, and Log\error().

Here is the call graph for this function:

Member Function Documentation

◆ getModuleName()

getModuleName ( )

Get module name

Returns: string Module name

Definition at line 293 of file class.fibermoduleloader.php.

                                   : string
    {
        return $this->moduleName;
    }

References $moduleName.

◆ getResult()

getResult ( )

Get result from module loader

Returns: mixed The loader's return value

Definition at line 303 of file class.fibermoduleloader.php.

    {
        return $this->result;
    }

References $result.

◆ isReady()

isReady ( )

Check if module is ready

Returns: bool True if loading complete

Definition at line 263 of file class.fibermoduleloader.php.

                             : bool
    {
        return $this->initialized || $this->fiber->isTerminated();
    }

◆ isSuspended()

isSuspended ( )

Check if fiber is suspended (mid-execution)

Returns: bool True if suspended

Definition at line 273 of file class.fibermoduleloader.php.

                                 : bool
    {
        return $this->fiber->isSuspended();
    }

◆ isTerminated()

isTerminated ( )

Check if fiber is terminated

Returns: bool True if finished

Definition at line 283 of file class.fibermoduleloader.php.

                                  : bool
    {
        return $this->fiber->isTerminated();
    }

◆ wait()

wait ( int $timeout = 5000 )

Wait for module to finish loading Returns immediately if already done

Parameters

int $timeout Maximum wait time (ms)

Returns: bool True if loaded, false if timeout

Definition at line 218 of file class.fibermoduleloader.php.

                                           : bool
    {
        if ($this->initialized) {
            return true;
        }
 
        $start = microtime(true);
        $maxWait = $timeout / 1000;
 
        while (!$this->initialized) {
            // Try to resume the fiber if suspended
            if ($this->fiber->isSuspended()) {
                try {
                    $this->fiber->resume();
                } catch (Throwable $e) {
                    Log::error('Fiber resume error: ' . $e->getMessage());
                    $this->initialized = true;
                    break;
                }
            }
 
            // Check if fiber completed
            if ($this->fiber->isTerminated()) {
                $this->initialized = true;
                break;
            }
 
            // Timeout check
            if ((microtime(true) - $start) > $maxWait) {
                Log::warning('Timeout waiting for module: ' . $this->moduleName);
                return false;
            }
 
            // Prevent busy-waiting (yield to other operations)
            usleep(1000);
        }
 
        return true;
    }