C使用pthreads互斥鎖同步問題

Question

我正在使用一個簡單的隊列實現，我試圖做一個簡單的程序，它有兩個線程：隊列中的第一個隊列事件和第二個隊列處理它們。我正在使用互斥鎖來避免同步問題。但是，我仍然經常（並非總是）出現分段錯誤。

請注意，我也使用-D_REENTRANT選項建立了我的代碼。另外，如果僅從一個線程調用隊列/出隊，則代碼工作得很好。

下面是簡單的代碼，顯示我是如何同步的東西：

int main(void) { 
    init_queue(&my_queue); 

    pthread_t thread_queue, thread_process; 
    int iret1, iret2; 

    iret1 = pthread_create(&thread_queue, NULL, svetlin_queue_events, (void*) NULL); 
    iret2 = pthread_create(&thread_process, NULL, svetling_process_events, (void*) fb); 

    pthread_join(thread_queue, NULL); 
    pthread_join(thread_process, NULL); 
} 

的排隊功能：

void svetlin_queue_events(void * v) { 
    int fd; 
    if ((fd = open("/dev/input/mouse1", O_RDONLY)) == -1) { 
     printf("error with touchscreen device\n"); 
     exit(1); 
    } 

    struct input_event ev; 
    struct input_event *being_sent; 
    int rd; 

    while (1) { 
     read(fd, &ev, sizeof(struct input_event)); 

     being_sent = malloc(sizeof(struct input_event)); 
     memcpy(being_sent, &ev, sizeof(struct input_event)); 

     pthread_mutex_lock(&my_mutex); 
     enqueue(&my_queue, being_sent); 
     pthread_mutex_unlock(&my_mutex); 

     printf("enqueueing...\n"); 
    } 
} 

和處理功能：

void svetling_process_events(void *v) { 

    printf("FB pointer is: %p\n", fb); 

    int x, y = 0; 
    int has_item = 0; 
    struct input_event **being_fetched; 
    struct input_event *ev; 

    while(1) { 

     pthread_mutex_lock(&my_mutex); 
     has_item = dequeue(&my_queue, being_fetched); 
     pthread_mutex_unlock(&my_mutex); 

     if (has_item) { 
      ev = *being_fetched; 
      printf("dequeueing...\n"); 
      if (ev->type == 3) { 
       if (ev->code == 0) { 
        x = ev->value; 
       } 

       if (ev->code == 1) { 
        y = ev->value; 
       } 
      } 
     } 
    } 
} 

我希望我用這麼多代碼不會讓你感到困惑，但它確實很簡單。

所以我的問題是關於同步我做錯了什麼？

謝謝！

UPDATE

這裏的隊列實現：

struct queue_node 
{ 
    struct queue_node *next; 
    void *data; 
}; 

struct queue 
{ 
    struct queue_node *first; 
    struct queue_node *last; 
}; 

int enqueue(struct queue *q, void * const value) 
{ 
    struct queue_node *node = malloc(sizeof(struct queue_node)); 

    if (node == NULL) { 
     errno = ENOMEM; 
     return 1; 
    } 

    node->data = value; 

    if (q->first == NULL) { 
     q->first = q->last = node; 
    } else { 
     q->last->next = node; 
     q->last = node; 
    } 

    node->next = NULL; 
    return 0; 
} 

int dequeue(struct queue *q, void **value) 
{ 
    if (!q->first) { 
     value = NULL; 
     return 0; 
    } 
    *value = q->first->data; 
    q->first = q->first->next; 
    return 1; 
} 

void init_queue(struct queue *q) 
{ 
    q->first = q->last = NULL; 
} 

int queue_empty_p(const struct queue *q) 
{ 
    return q->first == NULL; 
} 

它出現segfaults在dequeue行*value = q->first->data;。

謝謝！

Answer 1

一個次要的問題是：

if (!q->first) { 
    *value = NULL; 
    return 0; 
} 

（注意加星號）。

主要問題似乎是您在process_events函數中沒有爲*being_fetched分配內存。

說實話，我會將該變量的類型改爲，並簡單地將其地址傳遞給dequeue：has_item = dequeue(&my_queue, &being_fetched)。這也可以讓你擺脫ev作爲一個單獨的變量。

Answer 2

正如aix所說，你沒有init * being_fetched。但我認爲你最好還是不同定義它：

struct input_event *being_fetched; 
... 
has_item = dequeue(&my_queue, &being_fetched); 
... 
ev = being_fetched; 

然後讓絕對確保你修復AIX提到了其他錯誤，否則你不會得到空指針背出功能。