boost asio async_write:如何不交错async_write调用？

在使用Boost.Asio库进行异步编程时，如果需要确保多个async_write操作不交错，可以使用boost::asio::write或boost::asio::async_write函数，并在每次写操作完成后调用回调函数。这样可以确保在写入下一个数据块之前，当前数据块已经完全写入。

以下是一个使用boost::asio::async_write的示例，确保不交错的写入操作：

#include<boost/asio.hpp>
#include<iostream>
#include<vector>
#include<boost/bind.hpp>
#include<boost/enable_shared_from_this.hpp>

class Session : public boost::enable_shared_from_this<Session> {
public:
    Session(boost::asio::io_service& io_service)
        : socket_(io_service) {}

    boost::asio::ip::tcp::socket& socket() {
        return socket_;
    }

    void start() {
        boost::asio::async_write(socket_,
            boost::asio::buffer(data_, data_.size()),
            boost::bind(&Session::handle_write, shared_from_this(),
                boost::asio::placeholders::error,
                boost::asio::placeholders::bytes_transferred));
    }

private:
    void handle_write(const boost::system::error_code& error,
        size_t bytes_transferred) {
        if (!error) {
            // 写入下一个数据块
            start();
        }
    }

    boost::asio::ip::tcp::socket socket_;
    std::vector<char> data_ = {'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j'};
};

int main() {
    boost::asio::io_service io_service;

    boost::asio::ip::tcp::endpoint endpoint(boost::asio::ip::address::from_string("127.0.0.1"), 8080);
    boost::asio::ip::tcp::acceptor acceptor(io_service, endpoint.protocol());
    acceptor.bind(endpoint);
    acceptor.listen();

    boost::asio::ip::tcp::socket socket(io_service);
    acceptor.accept(socket);

    boost::shared_ptr<Session> session(new Session(io_service));
    session->socket() = std::move(socket);
    session->start();

    io_service.run();

    return 0;
}

在这个示例中，我们创建了一个Session类，它包含了一个boost::asio::ip::tcp::socket对象和一个包含数据的std::vector<char>对象。Session类的start方法使用boost::asio::async_write函数异步写入数据，并在写入完成后调用handle_write回调函数。在handle_write回调函数中，我们再次调用start方法，确保下一个数据块在当前数据块写入完成后再写入。

这样，我们就可以确保多个async_write操作不交错，每次写入一个完整的数据块。