c - 多线程，不能让另一个线程工作

Question

我正在尝试为每个传入的请求创建一个线程。这是我正在制作的一个简短示例。问题是我可以将第一个传入请求写入列表，但是当我尝试发送第二个请求时，它会在需要向我的函数“request_loop”发送信号时停止工作。

所以它在那里工作完美。有谁知道如何解决这个问题？该程序不想做比这更进一步的工作。

#include <stdio.h> 
#include <stdlib.h> 
#include <unistd.h> 
#include <fcntl.h> 
#include <errno.h> 
#include <string.h> 
#include "tcpsocket.h" 
#include <sys/select.h> 
#include <sys/time.h> 
#include <sys/types.h> 
#include <pthread.h> 

#define NUM_HANDLER_THREADS 3 /* number of threads used to service requests */
pthread_mutex_t request_mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t got_request = PTHREAD_COND_INITIALIZER;

unsigned char buffer[BUFSIZE]; 
unsigned char collect_buffers[2000];

struct timespec timeout; 
struct timeval tv;

int num_requests = 0;
int num; 
int rc = 0;
struct request {
    int number;
    struct request* next;
};
struct request* requests = NULL;
struct request* last_request = NULL;

这是我添加请求的函数。当我想将第二个线程写入我的列表时，它停止工作...

void add_request(int request_num,pthread_mutex_t* p_mutex,pthread_cond_t* p_cond_var)
{
    int rc;
    struct request* a_request;
    a_request = (struct request*)malloc(sizeof(struct request));
    if (!a_request) { /* malloc failed?? */
        fprintf(stderr, "add_request: out of memory\n");
        exit(1);
    }
    a_request->number = request_num;
    a_request->next = NULL;

    rc = pthread_mutex_lock(p_mutex);

    printf("NUMBER OF REQUESTS: %d\n",num_requests);
    if (num_requests == 0) { /* special case - list is empty */
        printf("list is empty\n");
        requests = a_request;
        last_request = a_request;
        printf("REQUEST NUMBER:%d",a_request->number);
    }else{
        printf("created list\n");
        last_request->next = a_request;
        last_request = a_request;
    }

    num_requests++;
    rc = pthread_mutex_unlock(p_mutex);
    printf("send signal");
    rc = pthread_cond_signal(p_cond_var);
    printf("signal sended");
}

这是我想将数据写入列表的函数。之后，我删除了请求:free(request);

struct request* get_request(pthread_mutex_t* p_mutex){
    printf("NUMBER REQUESTS (get request): %d\n",num_requests);    
    int rc;
    struct request* a_request;

    rc = pthread_mutex_lock(p_mutex);
    if (num_requests > 0) {
        a_request = requests;
        requests = a_request->next;
        printf("REQUEST NUMBER:%d\n",a_request->number);
        if (requests == NULL) { /* this was the last request on the list */
            last_request = NULL;
            printf("last request is NULL\n\n");
        }
        num_requests--; //remove REQUEST
    }else { /* requests list is empty */
        printf("list is empty\n");
        a_request = NULL;
    }
    //remove request
    free(a_request);

    rc = pthread_mutex_unlock(p_mutex);
    /* return the request to the caller. */
return a_request;
}

这是我处理请求直到不再有请求的循环

void* handle_requests_loop(void* data){
    //rc = pthread_mutex_lock(&request_mutex);    
    printf("NUMBER REQUESTS (loop): %d\n",num_requests);
    int rc;
    struct request* a_request;
    int thread_id = *((int*)data);

    while(num_requests > 0){

        printf("THREAD ID : %d\n",thread_id);
        a_request = get_request(&request_mutex);

        if(num_requests == 0){
            printf("NO REQUESTS\n\n");
        }else{
            printf("THERE ARE REQUESTS\n\n");
        }

    }
    while(num_requests == 0){
        printf("wait");
        rc = pthread_cond_wait(&got_request, &request_mutex);

    }
}

我为此编写了一个生成 2 个线程的测试函数。第一个工作正常，另一个在需要向线程循环发送新信号时停止工作。

int main(int argc, char* argv[]){ 
    printf("StartUp\n"); 

    //---------------------------Create Threads--------------------------------
    for (i=0; i<NUM_HANDLER_THREADS; i++) {
        thr_id[i] = i;
    pthread_create(&p_threads[i], NULL, handle_requests_loop,(void*)&thr_id[i]);
    }

    //--------------------------INTERRUPT--------------------------------------
    int j;
    for(j=1;j<3;j++){
    printf("ADD REQUEST\n");
    add_request(j, &request_mutex, &got_request);

    delay.tv_sec = 5;
    delay.tv_nsec = 10;
    nanosleep(&delay,NULL);

    } 
      return 0; 
}

有谁知道如何解决这个问题？非常感谢!!

Answer 1

我无法确定您的具体问题是什么。我需要你更具体地说明当你只有一个接收器线程时会发生什么，并在调试器中运行并告诉我们你的每个线程卡在哪一行代码。从您的文章中不清楚，例如，是主线程还是其中一个子线程“卡住了”。当您只创建一个子线程(更不用说两个子线程)而不是三个时，您是否观察到卡住也不清楚。

那是说有一个错误，还有一些您可以清理的东西，当您尝试自己解决这些问题时，这些东西会让您自己更轻松。

错误在于 handle_requests_loop() 的底部你调用pthread_cond_wait()与 &request_mutex 即使您目前没有 request_mutex锁定。这会导致未定义的行为(可能包括永久禁用调用 pthread_cond_wait() 或 pthread_cond_signal() 的一个或两个线程)。

在您可以清理的东西中:

1. 你正在用 PTHREAD_MUTEX_INITIALIZER 初始化你的互斥锁.这会创建非递归 互斥锁。如果同一个线程试图锁定互斥体两次，它就会与自身发生死锁。您应该使用 PTHREAD_MUTEX_RECURSIVE 的属性进行初始化或者非常小心不要双重锁定。例如:如果您取消注释 pthread_mutex_lock()在第一行调用 handle_requests_loop()当你调用 pthread_mutex_lock() 时，你肯定会陷入僵局在 get_request() 的第 5 行.
2. 您在 main() 中创建了一些线程但不要打电话 pthread_join() .现在这可能没问题，但在未来的某个时候你可能会不假思索地调用 pthread_create()引用 main() 堆栈上的某些数据，那 会导致严重的问题(未定义的行为。)
3. 你要离开了handle_requests_loop()既没有 return声明也不调用pthread_exit() .您需要一个或另一个(至少返回 NULL)。
4. 我不知道你在用requests做什么对比last_request而不是只有一个变量。 (它看起来不对，但我想不出来，所以它可能，纯粹的运气，没问题。)
5. 您正在释放 a_request靠近 get_request() 的底部但随后将其返回到 handle_requests_loop .从长远来看，这只会导致悲伤和伤害感情。