“operation now in progress”错误通常表明一个非阻塞操作仍在进行中，但后续调用试图操作相同的文件描述符。1. 使用select或poll检查文件描述符是否可读/写，以确保在操作前等待其变为可用状态；2. 采用信号处理机制正确中断操作，例如检查errno是否为eintr并决定重试或放弃；3. 调试时可通过增加日志输出、使用strace跟踪系统调用、使用gdb调试程序以及简化代码来定位问题；4. 其他解决方案包括epoll（高效的i/o多路复用机制）、线程或进程池（用于处理大量并发连接）以及异步i/o（aio，通过信号或回调通知操作完成）。选择哪种方案取决于具体需求和应用场景。
解决方案
这个错误，”Operation now in progress”，在linux环境下，遇到它的时候，往往让人有点摸不着头脑。它不像”File not found”那样直白，但它通常意味着你的程序在进行非阻塞I/O操作时遇到了麻烦。想象一下，你让一个快递员送货（非阻塞I/O），你告诉他送完就走，不用等收货人签收。结果你又马上让另一个快递员去送同样的货，那肯定会出问题。
所以，问题的核心在于，你可能在没有确认上一个非阻塞操作完成的情况下，就尝试进行下一个操作。这通常发生在网络编程，特别是使用socket的时候。
使用select或poll检查文件描述符状态
最常见的解决方案是使用select或poll系统调用。这两个函数允许你监视多个文件描述符，等待它们变为可读、可写或发生错误。
例如，假设你正在使用非阻塞socket进行接收数据：
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <fcntl.h> #include <errno.h> #include <sys/select.h> #define PORT 8080 #define BUFFER_SIZE 1024 int main() { int sockfd, new_socket; struct sockaddr_in address; int addrlen = sizeof(address); char buffer[BUFFER_SIZE] = {0}; // 创建socket if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == 0) { perror("socket failed"); exit(EXIT_FAILURE); } address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(PORT); // 绑定socket if (bind(sockfd, (struct sockaddr *)&address, sizeof(address)) < 0) { perror("bind failed"); exit(EXIT_FAILURE); } // 监听连接 if (listen(sockfd, 3) < 0) { perror("listen"); exit(EXIT_FAILURE); } // 设置socket为非阻塞 int flags = fcntl(sockfd, F_GETFL, 0); if (fcntl(sockfd, F_SETFL, flags | O_NONBLOCK) < 0) { perror("fcntl"); exit(EXIT_FAILURE); } printf("Server listening on port %d...n", PORT); // 接受连接 if ((new_socket = accept(sockfd, (struct sockaddr *)&address, (socklen_t*)&addrlen))<0) { if (errno == EWOULDBLOCK || errno == EAGAIN) { printf("No pending connectionsn"); } else { perror("accept"); exit(EXIT_FAILURE); } } if(new_socket > 0){ printf("Connection acceptedn"); // 使用select来等待数据 fd_set readfds; FD_ZERO(&readfds); FD_SET(new_socket, &readfds); struct timeval timeout; timeout.tv_sec = 5; timeout.tv_usec = 0; int activity = select(new_socket + 1, &readfds, NULL, NULL, &timeout); if ((activity < 0) && (errno!=EINTR)) { perror("select error"); printf("select errorn"); } if (activity > 0) { if (FD_ISSET(new_socket, &readfds)) { // 接收数据 ssize_t valread = recv(new_socket, buffer, BUFFER_SIZE, 0); if (valread > 0) { printf("Received: %sn", buffer); } else if (valread == 0) { printf("Client disconnectedn"); } else { perror("recv"); } } } else { printf("Timeout occurredn"); } } close(new_socket); close(sockfd); return 0; }
在这个例子中，select函数会阻塞，直到new_socket变为可读（即有数据到达），或者超时。如果在超时时间内没有数据到达，select会返回0，你可以处理超时的情况。这避免了在recv之前盲目地调用它，从而避免了”Operation now in progress”错误。
信号处理机制
另一种情况是，你的操作可能被信号中断。例如，如果你的程序接收到一个SIGINT信号（通常是用户按下Ctrl+C），正在进行的系统调用可能会被中断，并返回EINTR错误。你需要检查errno是否为EINTR，如果是，则决定是重试操作还是放弃。
ssize_t bytes_received; while (1) { bytes_received = recv(sockfd, buffer, BUFFER_SIZE, 0); if (bytes_received < 0) { if (errno == EINTR) { // 被信号中断，重试 continue; } else { perror("recv"); break; } } else if (bytes_received == 0) { // 连接关闭 printf("Connection closed by peern"); break; } else { // 成功接收到数据 printf("Received: %sn", buffer); break; } }
这个循环会不断重试recv，直到成功接收到数据、连接关闭或发生其他错误。
为什么非阻塞I/O会产生这个错误？
非阻塞I/O的目的是让程序在等待I/O操作完成时，可以继续执行其他任务。但这也就意味着，你需要自己负责检查I/O操作是否已经完成。如果没有正确处理，就可能出现”Operation now in progress”错误。想象一下，你让快递员送货，并且告诉他不用等签收就走。然后，你又立刻让另一个快递员送同样的货。如果第一个快递员还没把货送到，第二个快递员就会发现货已经在路上了，这就是非阻塞I/O可能出现的问题。
如何调试这类错误？
调试这类错误可能比较棘手，因为它通常涉及到并发和时序问题。你可以尝试以下方法：
- 增加日志输出： 在关键的代码路径上添加日志输出，例如在调用recv、send、accept等函数前后，记录函数参数和返回值。
- 使用strace： strace是一个非常有用的工具，它可以跟踪程序的系统调用。你可以使用strace来查看程序实际执行了哪些系统调用，以及它们的返回值。这可以帮助你找到问题的根源。例如：strace -p ，其中是你的程序的进程ID。
- 使用gdb： 如果你有程序的源代码，可以使用gdb来调试程序。设置断点，单步执行，查看变量的值，可以帮助你理解程序的行为。
- 简化代码： 尝试简化你的代码，减少并发的数量，看看是否还能重现这个问题。如果简化后的代码不再出现问题，那么问题很可能与并发有关。
除了select和poll，还有其他解决方案吗？
是的，除了select和poll，还有一些其他的解决方案：
- epoll： epoll是Linux特有的I/O多路复用机制，它比select和poll更高效，特别是在处理大量文件描述符时。epoll使用事件驱动的方式，只有当文件描述符真正发生变化时，才会通知应用程序。
- 使用线程或进程池： 如果你的程序需要处理大量的并发连接，可以考虑使用线程或进程池。每个线程或进程负责处理一个连接，这样可以避免阻塞I/O带来的问题。
- 异步I/O (AIO)： 异步I/O允许你发起一个I/O操作，然后立即返回，而不需要等待I/O操作完成。当I/O操作完成时，系统会通过信号或回调函数通知你。AIO可以显著提高程序的性能，但它也比较复杂，需要仔细设计和实现。
选择哪种解决方案取决于你的具体需求和应用场景。对于简单的程序，select或poll可能就足够了。对于高性能的服务器，epoll或AIO可能更适合。
