static char *TCPCommand; static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; int SetUpTCPtoSendInformation(char option[], char *command) { static int isFirstCall = 1; pthread_mutex_lock(&mutex); // 加锁 if (isFirstCall && strstr(option, "set")) { TCPCommand = malloc(strlen(command) + 1); if (TCPCommand == NULL) { CON_LOG("Failed to set and obtain TCP command variable memory allocation"); goto fail; } strcpy(TCPCommand, command); isFirstCall = 0; goto succeed; } else if (!isFirstCall && strstr(option, "get") && TCPCommand != NULL && strlen(TCPCommand)) { strcpy(command, TCPCommand); memset(TCPCommand, '\0', strlen(TCPCommand)); free(TCPCommand); isFirstCall = 1; goto succeed; } memset(command, 0, sizeof(command)); strcpy(command, ""); fail: pthread_mutex_unlock(&mutex); // 解锁 return 0; succeed: pthread_mutex_unlock(&mutex); // 解锁 return 1; }多线程调用 此函数
时间: 2024-04-09 18:31:53 浏览: 81
pthread_cond_wait() 用法深入分析
是一个用于设置和获取TCP命令的函数,支持多线程调用。函数的输入参数包括一个选项(option)和一个命令(command)。函数的逻辑如下:
1. 使用静态变量TCPCommand存储TCP命令。静态变量保证在函数调用之间保持其值不变。
2. 使用互斥锁(mutex)来确保在多线程环境下对TCPCommand的操作是线程安全的。
3. 如果是第一次调用并且选项字符串中包含"set",则为TCPCommand分配内存,并将命令字符串复制到TCPCommand中。
4. 如果不是第一次调用并且选项字符串中包含"get",并且TCPCommand不为NULL且长度不为0,则将TCPCommand的值复制到命令字符串中,并清空TCPCommand的值,并释放内存。
5. 如果以上条件都不满足,则将命令字符串清空。
6. 如果内存分配失败,则打印错误信息并返回0,表示失败。
7. 如果执行成功,则返回1,表示成功。
在函数执行过程中,使用互斥锁来确保对共享变量TCPCommand的访问是线程安全的。在函数开始时使用pthread_mutex_lock函数加锁,在函数结束时使用pthread_mutex_unlock函数解锁。这样可以防止多个线程同时对TCPCommand进行读写操作导致数据不一致的问题。
阅读全文