树莓派 usb转4路485,开启两个线程,实现两个串口的实时通信,写一个c++demo
时间: 2024-04-14 07:25:39 浏览: 113
下面是一个使用两个线程实现两个串口实时通信的C++示例代码:
```cpp
#include <iostream>
#include <fcntl.h>
#include <termios.h>
#include <unistd.h>
#include <pthread.h>
// 串口设备文件路径
const char* SERIAL_PORT1 = "/dev/ttyUSB0";
const char* SERIAL_PORT2 = "/dev/ttyUSB1";
// 串口1读取线程函数
void* serialReadThread1(void* arg) {
int serialPort1 = open(SERIAL_PORT1, O_RDWR | O_NOCTTY | O_NDELAY);
if (serialPort1 == -1) {
std::cout << "无法打开串口1设备文件" << std::endl;
pthread_exit(nullptr);
}
// 配置串口1
struct termios options;
tcgetattr(serialPort1, &options);
cfsetispeed(&options, B9600); // 设置输入波特率为9600
cfsetospeed(&options, B9600); // 设置输出波特率为9600
options.c_cflag |= (CLOCAL | CREAD); // 使能接收和本地连接
options.c_cflag &= ~PARENB; // 禁用奇偶校验
options.c_cflag &= ~CSTOPB; // 设置停止位为1
options.c_cflag &= ~CSIZE; // 清除数据位设置
options.c_cflag |= CS8; // 设置数据位为8
tcsetattr(serialPort1, TCSANOW, &options);
char recvData[256];
while (true) {
int recvBytes = read(serialPort1, recvData, sizeof(recvData));
if (recvBytes > 0) {
std::cout << "串口1接收到的数据:" << recvData << std::endl;
}
}
close(serialPort1);
pthread_exit(nullptr);
}
// 串口2读取线程函数
void* serialReadThread2(void* arg) {
int serialPort2 = open(SERIAL_PORT2, O_RDWR | O_NOCTTY | O_NDELAY);
if (serialPort2 == -1) {
std::cout << "无法打开串口2设备文件" << std::endl;
pthread_exit(nullptr);
}
// 配置串口2
struct termios options;
tcgetattr(serialPort2, &options);
cfsetispeed(&options, B9600); // 设置输入波特率为9600
cfsetospeed(&options, B9600); // 设置输出波特率为9600
options.c_cflag |= (CLOCAL | CREAD); // 使能接收和本地连接
options.c_cflag &= ~PARENB; // 禁用奇偶校验
options.c_cflag &= ~CSTOPB; // 设置停止位为1
options.c_cflag &= ~CSIZE; // 清除数据位设置
options.c_cflag |= CS8; // 设置数据位为8
tcsetattr(serialPort2, TCSANOW, &options);
char recvData[256];
while (true) {
int recvBytes = read(serialPort2, recvData, sizeof(recvData));
if (recvBytes > 0) {
std::cout << "串口2接收到的数据:" << recvData << std::endl;
}
}
close(serialPort2);
pthread_exit(nullptr);
}
int main() {
// 创建串口1读取线程
pthread_t thread1;
if (pthread_create(&thread1, nullptr, serialReadThread1, nullptr) != 0) {
std::cout << "无法创建串口1读取线程" << std::endl;
return -1;
}
// 创建串口2读取线程
pthread_t thread2;
if (pthread_create(&thread2, nullptr, serialReadThread2, nullptr) != 0) {
std::cout << "无法创建串口2读取线程" << std::endl;
return -1;
}
// 主线程等待子线程结束
pthread_join(thread1, nullptr);
pthread_join(thread2, nullptr);
return 0;
}
```
在主函数中,我们创建了两个线程分别用于读取两个串口(`/dev/ttyUSB0`和`/dev/ttyUSB1`)的数据。每个线程都打开对应的串口设备文件,并进行配置。然后,通过循环读取数据并输出。主线程通过调用`pthread_join()`函数等待两个子线程结束。
请注意,以上代码仅提供了基本的串口读取功能,并没有包括串口写入的部分。你可以根据实际需要扩展代码,并根据具体的通信协议进行数据的解析和处理。同时,确保你已经安装了相关的串口驱动和依赖库。
阅读全文