byjg / phpthread

example.php

<?php

For compatibility and reusability of your code, PSR1 recommends that a file should introduce either new symbols (like classes, functions, etc.) or have side-effects (like outputting something, or including other files), but not both at the same time. The first symbol is defined on line 4 and the first side effect is on line 2.

require_once('vendor/autoload.php');

class Foo

This class seems to be duplicated in your project.

PSR1 recommends that each class must be in a namespace of at least one level to avoid collisions.

{
// Method to be executed in a thread
    public function bar($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();

    $foo = new Foo();

    // 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, 'bar']);

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