PHP Pthreads - używanie mysqli

Problem polega na tym, że obiekt mysqli nie nadaje się do użycia w wielu wątkach, chcesz utworzyć instancję MySQLi dla każdego uruchamianego wątku, więc każdy wątek ma unikalne połączenie.

<?php
define("SQLHOST", "localhost");
define("SQLUSER", "root");
define("SQLPASS", "");
define("SQLDB",   "test");
define("SQLPORT", 3306);
define("SQLSOCK", "/var/lib/mysql/mysql.sock");

class Mine extends Thread {
    public function run() {
        try {
            $my = new mysqli(SQLHOST, SQLUSER, SQLPASS, SQLDB, SQLPORT, SQLSOCK);
            if ($my) {
                $result = $my->query("SHOW DATABASES;");

                if (is_object($result)) {
                    while (($row = $result->fetch_assoc())) {
                        var_dump($row);
                    }
                }
            }
        } catch(Exception $ex) {
            var_dump($ex);
        }
    }
}

$mine = new Mine();
$mine->start();
?>

Plony

array(1) {
  ["Database"]=>
  string(18) "information_schema"
}
array(1) {
  ["Database"]=>
  string(5) "mysql"
}
array(1) {
  ["Database"]=>
  string(18) "performance_schema"
}
array(1) {
  ["Database"]=>
  string(4) "test"
}

Zwróć uwagę, że obiekt MySQLi nigdy nie jest przechowywany w zakresie obiektu Threads, ponieważ należy przechowywać w zakresie obiektu tylko to, co zamierzasz udostępnić, a ponieważ nie możesz udostępnić połączenia MySQLi, najlepiej jest manipulować nim w zakresie metody .

Istnieje wiele przykładów na github, w tym przykład SQLWorker, powinieneś je wszystkie przeczytać.

Dalsza lektura:https://gist.github.com/krakjoe/6437782