linux串口编程 线程

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#include <termios.h>
#include <pthread.h>

int serial_port;

void *read_serial(void *arg) {
    char buffer[256];
    while (1) {
        int n = read(serial_port, &buffer, sizeof(buffer));
        if (n < 0) {
            perror("read");
            break;
        } else if (n > 0) {
            buffer[n] = '\0';
            printf("Received data: %s
", buffer);
        }
    }
    return NULL;
}

int main() {
    serial_port = open("/dev/ttyS0", O_RDWR);
    if (serial_port < 0) {
        perror("open");
        return EXIT_FAILURE;
    }

    struct termios tty;
    if (tcgetattr(serial_port, &tty) != 0) {
        perror("tcgetattr");
        return EXIT_FAILURE;
    }

    cfsetospeed(&tty, B9600);
    cfsetispeed(&tty, B9600);

    tty.c_cflag |= (CLOCAL | CREAD);
    tty.c_cflag &= ~PARENB;
    tty.c_cflag &= ~CSTOPB;
    tty.c_cflag &= ~CSIZE;
    tty.c_cflag |= CS8;

    if (tcsetattr(serial_port, TCSANOW, &tty) != 0) {
        perror("tcsetattr");
        return EXIT_FAILURE;
    }

    pthread_t thread_id;
    if (pthread_create(&thread_id, NULL, read_serial, NULL) != 0) {
        perror("pthread_create");
        return EXIT_FAILURE;
    }

    pthread_join(thread_id, NULL);

    close(serial_port);
    return EXIT_SUCCESS;
}