C++ boost::asioを利用したシリアル通信で非同期受信(async_read)をしたい

Question

概要

・PC(USB)⇔相手機器(RS485)という形式で接続しシリアル通信を行っています
・PCからコマンドを送信すると相手機器はそれに反応し、結果をPC側に送信する仕様となります
・コマンドによって送信データのサイズは変動し、受信するデータのサイズもそれに合わせて変動します
・boost::asio::write関数で同期送信し、boost::asio::async_read関数で非同期受信をします
・現状のコードだとwriteによる送信で相手機器に反応はありますが、async_readのコールバック関数が呼ばれません

該当のソースコード

#include <iostream>
#include <iomanip>
#include <boost/thread/thread.hpp>
#include <boost/asio.hpp>

class CommSample
{
public:
    CommSample(const std::string& portname);
    ~CommSample();
    void test();
private:
    boost::thread _thread;
    unsigned char _receive_data[64];
    boost::asio::io_service _io;
    boost::asio::serial_port _port;
    void handler(const boost::system::error_code&, size_t);
};
CommSample::CommSample(const std::string& portname) : _io(), _port(_io)
{
        _port.open(portname);
        _port.set_option(boost::asio::serial_port_base::baud_rate(19200));
        _port.set_option(boost::asio::serial_port_base::character_size(8));
        _port.set_option(boost::asio::serial_port_base::flow_control(boost::asio::serial_port_base::flow_control::none));
        _port.set_option(boost::asio::serial_port_base::parity(boost::asio::serial_port_base::parity::none));
        _port.set_option(boost::asio::serial_port_base::stop_bits(boost::asio::serial_port_base::stop_bits::one));
        boost::asio::io_service::work w(_io);
        boost::thread t(boost::bind(&boost::asio::io_service::run, &_io));
        _thread = boost::move(t);
}
CommSample::~CommSample()
{
    _io.stop();
    _thread.join();
}
void CommSample::test()
{
    constexpr int receive_size = 8;
    unsigned char send_data[6]{0x01, 0x02, 0x03, 0x04, 0x05, 0x06};
    boost::asio::async_read(_port,
                            boost::asio::buffer(_receive_data),
                            boost::asio::transfer_exactly(receive_size),
                            boost::bind(&CommSample::handler,
                            this,
                            boost::asio::placeholders::error,
                            boost::asio::placeholders::bytes_transferred));
    boost::asio::write(_port, boost::asio::buffer(send_data));
}
void CommSample::handler(const boost::system::error_code& error, size_t bytes_transferred)
{
    for (size_t i = 0; i < bytes_transferred; i++)
    {
        std::cout << std::uppercase << std::setfill('0') << std::hex << std::setw(2) << (int)_receive_data[i];
    }
}
int main()
{
    CommSample a("COM3");
    while (true)
    {
        char c = getchar();
        if (c == 'q')break;
        if (c == 'a')a.test();
    }
    return 0;
}

試したこと

ネットで調べますとio_service::run関数は処理するものがないと終了するそうで
見様見真似ですがboost::asio::io_service::work w(_io);というものをスレッド作成前に呼んでいます
しかしio_service::stopped()関数はコンストラクタを呼んだ直後には既にtrueを返してしまいます

async_readではなく
read(_port,boost::asio::buffer(_receive_data),boost::asio::transfer_exactly(receive_size));
の同期関数に変更すると受信したいデータがちゃんと_receive_dataに格納されています
write関数の後にこれは書きました

どこを修正したら良いでしょうか？
write関数は今回の目的が実現できるのであればasync_write関数に変更可能です

Answer 1

自己解決しました
boost::asio::io_service::work w(_io);
は正しかったのですが
コンストラクタ内で書いていたのでコンストラクタが終了した時点で
wも寿命を迎えていました
メンバ変数にboost::asio::io_service::work w;を持ち
コンストラクタでw(_io)と初期化しましたら動きました