mongo and pthreads extensions

console.log

$ php threads.php 
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
b: getmore
a: getmore
b: getmore
a: getmore
b: getmore
a: getmore
a: getmore
b: getmore
a: getmore
b: getmore
a: getmore
b: getmore
a: getmore
a: getmore
b: getmore
a: getmore
b: getmore
a: getmore
b: getmore
a: getmore
b: getmore
a: getmore
b: closing MongoClient and returning
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore
a: getmore

threads.php

<?php

$mc = new MongoClient();
$collection = $mc->test->foo;
$collection->drop();

for ($i = 0; $i < 1000; ++$i) {
    $collection->insert(['x' => $i]);
}

$mc->close();
unset($mc, $collection);

class WorkerThread extends Worker
{
    public function __construct($name)
    {
        $this->name = $name;
    }

    public function run()
    {
        $name = $this->name;
        $getmores = 0;

        $ctx = stream_context_create(array(
            'mongodb' => array(
                'log_getmore' => function($server, $info) use ($name, &$getmores) {
                    printf("%s: getmore\n", $name);
                    ++$getmores;
                },
            ),
        ));

        $mc = new MongoClient(null, array(), array('context' => $ctx));
        $cursor = $mc->test->foo->find();
        $cursor->batchSize(10);

        $i = 0;

        foreach ($cursor as $document) {
            ++$i;
            if ($name == 'b' && $getmores >= 10) {
                printf("%s: closing MongoClient and returning\n", $name);
                $mc->close();
                return;
            }
        }
    }
}

$workerA = new WorkerThread('a');
$workerB = new WorkerThread('b');
$workerA->start();
$workerB->start();
$workerA->join();
$workerB->join();