Unix/Linux编程：为阻塞操作设置超时

柔光的暖阳◎ 2023-01-04 13:26 181阅读 0赞

实时定时器的用途之一是为了某个阻塞系统调用**设置其处于阻塞状态的时间上限**。比如，当用户在一段时间内没有输入整行命令时，可能希望取消对终端的read()操作。处理如下：

*  调用sigaction()为SIGALRM信号创建处理器函数，但其弊端在于：
    
     *  可能干扰进程中现有的alarm调用，如timer、settimer、sleep等。
     *  在多线程化程序中正确使用信号却非常困难；所以建议只是在未线程化或单线程化的程序中使用本技术。
 *  调用 alarm()或 setitimer()来创建一个定时器，同时设定希望系统调用阻塞的时间上限
 *  执行阻塞式系统调用
    
     *  阻塞操作是指,在执行设备操作时,若不能获得资源,则进程挂起直到满足可操作的条件再进行操作
 *  系统调用返回后，再次调用 alarm()或 setitimer()以屏蔽定时器（以防止系统调用在定时器到期之前就已完成的情况）。
 *  检查系统调用失败时是否将 errno 置为 EINTR（系统调用遭到中断）。

#include <stdio.h>  
    #include <netinet/in.h>//for struct sockaddr_in  
    #include <string.h>//for memset  
    #include <signal.h>//for signal  
      
    typedef void (*sighandler_t)(int);  
      
    static void  
    read_alarm(int signo)  
    {
          
        return;  
    }  
      
    int main()  
    {
          
        int conn_sock;  
        struct sockaddr_in ser_addr;  
        int ret;  
        char buf[1024];  
        sighandler_t src_sig;  
        struct sigaction sa_alarm;  
      
        conn_sock = socket(AF_INET, SOCK_STREAM, 0);  
        if (conn_sock < 0)  
        {
          
            perror("socket error");  
            return -1;  
        }  
      
        memset(&ser_addr, 0, sizeof(ser_addr));  
        ser_addr.sin_family = AF_INET;  
        ser_addr.sin_port = htons(135);  
        inet_pton(AF_INET, "127.0.0.1", &ser_addr.sin_addr);  
      
        ret = connect(conn_sock, (struct sockaddr *)&ser_addr, sizeof(ser_addr));  
        if (ret < 0)  
        {
          
            perror("connect error");  
            return -1;  
        }  
      
        //src_sig = signal(SIGALRM, read_alarm);  
        sa_alarm.sa_flags = SA_RESETHAND;  
        sa_alarm.sa_handler = read_alarm;  
        sigaction(SIGALRM, &sa_alarm, NULL);  
        alarm(10);  
        ret = read(conn_sock, buf, sizeof(buf));  
        if (ret < 0)  
        {
          
            perror("read error");  
        }  
        else if (ret == 0)  
        {
          
            printf("close by peer\n");  
        }  
        else  
        {
          
            printf("recv %d bytes\n", ret);  
        }  
        alarm(0);  
        //signal(SIGALRM, src_sig);  
        return 0;  
    }