Comment empêcher l'entrelacement des appels d'écriture asynchrone dans Boost Asio ?

Appels d'écriture asynchrones entrelacés dans Boost Asio

Dans boost asio, les appels async_write peuvent s'entrelacer si plusieurs messages sont envoyés en succession rapide. Cela peut entraîner un comportement inattendu et une corruption des données. Pour éviter ce problème, une solution simple consiste à maintenir une file d'attente sortante pour chaque client.

Utiliser une file d'attente sortante

En utilisant une file d'attente sortante, vous pouvez vous assurer que les messages sont envoyés dans l’ordre de leur réception. Lorsqu'un nouveau message arrive, il est ajouté à la file d'attente. Le gestionnaire async_write vérifie la taille de la file d'attente et démarre une nouvelle opération async_write s'il y a plus de messages à envoyer.

Exemple d'implémentation

Voici un exemple d'implémentation d'une écriture asynchrone gestionnaire qui utilise une file d'attente sortante :

void writeHandler(const boost::system::error_code& error, const size_t bytesTransferred)
{
    _outbox.pop_front();

    if (error) {
        std::cerr << "could not write: " << boost::system::system_error(error).what() << std::endl;
        return;
    }

    if (!_outbox.empty()) {
        // more messages to send
        this->write();
    }
}

Dans cet exemple, le writeHandler démarre une nouvelle opération async_write s'il y a plus de messages dans la _outbox.

Protéger l'accès à la boîte d'envoi

Pour protéger l'accès à la _outbox, vous devez utiliser un brin ou une primitive de synchronisation. Un brin garantit qu'un seul thread peut exécuter le code qui accède à la _outbox à la fois, évitant ainsi les conditions de concurrence.

Points clés

• Maintenir une file d'attente sortante pour chaque client.
• Utilisez un gestionnaire async_write qui vérifie la taille de la file d'attente et démarre une nouvelle opération async_write s'il y a plus de messages à recevoir. envoyer.
• Protéger l'accès à la file d'attente sortante à l'aide d'un brin ou d'une primitive de synchronisation.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!