byjg/phpthread

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

$threadClosure = function ($t)
    {
        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($threadClosure);

        // 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;
}