以同步方式将全双工串行端口与 ASIO（或其他库）一起使用-解网

问：

我正在处理一个项目，我需要通过串行端口与设备进行通信。我一直在考虑使用 ASIO 库来处理通信，但我有几个问题：

串行端口本质上是全双工的吗？我可以同时读取和写入端口而不会出现任何问题吗？
如果我使用 ASIO，是否可以在不使用互斥锁的情况下从两个不同的线程对同一个 asio：：serial_port 对象执行同步读取和写入？具体来说，我想要一个线程专门用于阅读，另一个线程专门用于写作。需要注意的是，只有一个线程会写入，一个线程会读取，因此不可能有多个读取或写入，但同时读取和写入应该是可能的。
如果 ASIO 不是最佳选择，您是否推荐用于 C++ 中的同步串行端口通信的其他库？

现在，我使用互斥锁保护 asio：：serial_port，因此只能进行一次读取或写入。我正在以同步方式使用 ASIO。

C++ 串口 boost-asio asio 全双工

更简单的单线程异步

#include <boost/asio.hpp>
#include <boost/asio/serial_port.hpp>
#include <deque>
#include <iomanip>
#include <iostream>

namespace asio = boost::asio;
using sp       = asio::serial_port;
using boost::system::error_code;
using namespace std::literals;

struct Example {
    Example(asio::any_io_executor ex, std::string dev) : sp_(ex, dev) {
        readLoop();
    }

    void Send(std::string cmd) {
        std::cerr << "Queue: " << quoted(cmd) << std::endl;
        outbox_.push_back(std::move(cmd));
        if (outbox_.size() == 1)
            writeLoop();
    }

    void Stop() {
        sp_.cancel();
    }

  private:
    void readLoop() {
        asio::async_read_until( //
            sp_, asio::dynamic_buffer(incoming_), "\n", [this](error_code ec, size_t len) {
                std::cerr << "Read: " << len << " (" << ec.message() << ")" << std::endl;
                if (!ec.failed()) {
                    Send("echo: "s + incoming_.substr(0, len));
                    incoming_.erase(0, len);
                    readLoop();
                }
            });
    }
    void writeLoop() {
        if (outbox_.empty())
            return;
        asio::async_write(sp_, asio::buffer(outbox_.front()), [this](error_code ec, size_t len) {
            std::cerr << "Wrote: " << len << " (" << ec.message() << ")" << std::endl;
            if (!ec.failed()) {
                outbox_.pop_front();
                writeLoop();
            }
        });
    }

    asio::serial_port       sp_;
    std::string             incoming_;
    std::deque<std::string> outbox_;
};

int main(int argc, char** argv) {
    asio::io_context ioc;
    Example          drone(ioc.get_executor(), (argc > 1 ? argv[1] : "/dev/stty0"));

    ioc.run_for(30s);

    // not really needed, but to show graceful shutdown
    drone.Stop();
    ioc.run();
}

现场演示：

以同步方式将全双工串行端口与 ASIO（或其他库）一起使用

Using Full-Duplex Serial Port with ASIO (or other libraries) in a Synchronous Manner

评论

评论

更简单的单线程异步

评论