Code — un PDO avec pool, 3 coroutines
// Un seul objet PDO avec un pool de 2 connexions
$pdo = new PDO($dsn, $user, $pass, [
PDO::ATTR_POOL_ENABLED => true,
PDO::ATTR_POOL_MAX => 2,
]);
for ($i = 1; $i <= 3; $i++) {
spawn(function() use ($pdo, $i) {
// prepare() acquiert auto. une conn du pool
$stmt = $pdo->prepare("SELECT * FROM users WHERE id=?");
$stmt->execute([$i]); // attend la BD
$user = $stmt->fetch();
processUser($user);
// $stmt sort du scope -> refcount=0
// la conn retourne auto. au pool !
});
}
PDO Pool (ATTR_POOL_MAX: 2)
Connexion #1
disponible
Connexion #2
disponible
File d'attente :
vide
Coroutine 1
prête
Coroutine 2
prête
Coroutine 3
prête