如何使用专用线程接收UDP数据？

Question

我想使用专用线程使用 asio 库接收 udp 数据。下面给出了示例代码。

#define ASIO_STANDALONE // we are using the stand aloe version of ASIO and Not Boost::ASIO


#include <iostream>
#include "include/asio.hpp"
#include <array>
#include <thread>


class UDPServer
{

public:
    UDPServer( asio::io_service& ioService): m_socket(ioService)
    {}
    ~UDPServer(){}

    void listen(const int& port)
    {
        m_socket.open(asio::ip::udp::v4());
        m_socket.bind(asio::ip::udp::endpoint(asio::ip::udp::v4(), port));

#define DEDICATED_THREAD_FLAG  1

#if DEDICATED_THREAD_FLAG
        m_thread = std::thread( &UDPServer::receive, this);
        std::cout<<"Thead Id in listen:"<<std::this_thread::get_id()<<std::endl;
        m_thread.join();
#else
        receive();
#endif
    }

    template<std::size_t SIZE>
    void processReceivedData(const std::array<char, SIZE>& rcvdMessage,
                             const int& rcvdMessageSizeInBytes,
                             const std::error_code& error)
    {

        std::cout<<"Rcvd Message: "<<rcvdMessage.data()<<std::endl;
        receive();

    }
    void receive()
    {
        std::cout<<"Thead Id in receive0:"<<std::this_thread::get_id()<<std::endl;

        asio::ip::udp::endpoint m_udpRemoteEndpoint;

        m_socket.async_receive_from(asio::buffer(recv_buffer, recv_buffer.size()/*NetworkBufferSize*/), m_udpRemoteEndpoint,
                                    [this](std::error_code ec, std::size_t bytesReceived)
        {
            std::cout<<"Thead Id in receive1:"<<std::this_thread::get_id()<<std::endl;

            processReceivedData(recv_buffer, bytesReceived, ec);
        });

    }

private:
    asio::ip::udp::socket m_socket;
    std::thread m_thread;
    static const int NetworkBufferSize = 9000;
    std::array<char, NetworkBufferSize> recv_buffer;

};


int main()
{

    std::cout<<"Main Thead Id:"<<std::this_thread::get_id()<<std::endl;
    asio::io_service m_ioService;


    UDPServer myServer( m_ioService);
    myServer.listen(12345); // starting the UDP server

    std::cout<<"Program waiting.."<<std::endl;

    m_ioService.run();


    std::cout<<"Program ending.."<<std::endl;
}

可以通过将 DEDICATED_THREAD_FLAG 更改为 0 来启用非专用线程版本，这按预期工作。

但是，当DEDICATED_THREAD_FLAG设置为1时，一个新线程正在启动并进入"receive"函数。但是当一个udp数据包到达时，它只由主线程处理，而不是由专用线程处理。

这里出了什么问题？

Answer 1

处理异步调用的整个事件循环由 io_server 完成，您运行在主线程中完成。

而不是运行在线程中调用 receive 函数（它会立即 return），你应该运行 io_service::run.

如何使用专用线程接收UDP数据？

How to use a dedicated thread to receive UDP data?

c++

multithreading

udp

asio