byjg / phpthread

example.php

<?php
require_once('vendor/autoload.php');

// Method to be executed in a thread
function Foo($t)

This function seems to be duplicated in your project.

{
    echo "Starting thread #$t" . PHP_EOL;
    
    sleep(1 * rand(1, 5));
    for ($i = 0; $i < 10; $i++) {
        echo "Hello from thread #$t, i=$i" . PHP_EOL;
        sleep(1);
    }
    echo "Ending thread #$t" . PHP_EOL;

    // Note: this line below require the file "config/cacheconfig.php" exists
    return "$t: [[[[[[" . time() . "]]]]]]";
}

try {
    $t = array();

    // Create the threads
    for ($i = 0; $i < 10; $i++) {
        // Create a new instance of the Thread class, pointing to "Foo" function
        $thr = new \ByJG\PHPThread\Thread('Foo');

        // Started the method "Foo" in a tread
        $thr->execute($i);

        // Save the thread reference to be manipulate
        $t[] = $thr;
    }

    $done = false;

    // It is important to check if all threads are done
    // otherwise will be terminate when the php script is finished;
    foreach ($t as $thread) {
        $thread->waitFinish();
    }

    // Note: this line below require the file "config/cacheconfig.php" exists
    foreach ($t as $thread) {
        echo "Result: " . $thread->getResult() . "\n";
    }
    
} catch (Exception $e) {
    echo 'Exception: ' . $e . PHP_EOL;
}