1

我正在尝试为每个传入的请求创建一个线程。这是我正在制作的一个简短示例。问题是我可以将第一个传入请求写入列表，但是当我尝试发送第二个请求时，它会在需要向我的函数“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; 
}

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

4

1 回答 1

0

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

也就是说，有一个错误，以及一些你可以清理的东西，当你试图自己解决这些问题时，它们会让你自己更容易。

错误是，即使您当前没有lockhandle_requests_loop() ，您仍在调用pthread_cond_wait()with 。这会导致未定义的行为（可能包括永久禁用调用or的线程中的一个或两个）。&request_mutex request_mutexpthread_cond_wait() pthread_cond_signal()

您可以清理的内容包括：

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