取消或杀死pthread

gcc (GCC) 4.6.3
valgrind-3.6.1

我创建了一个应用程序，在2个不同的线程中发送和接收一些消息，用于发送和接收 . 使用pthreads，条件可变和锁定互斥锁 .

但是，发送方将发送消息，然后通知接收方接收消息并进行处理 . 它在while循环中执行此操作 .

但是，如果我想通过使用ctrl-c并处理中断来退出应用程序，则会出现问题 . 如果没有发送消息，则接收器卡在等待接收的while循环中 .

主线程将调用join和block等待接收器完成 . 但它没有等待 pthread_cond_wait .

我在考虑使用 pthread_cancel 或 pthread_kill . 但我不允许线程正常退出 .

非常感谢任何建议 .

main function

void main(void)
    {
        /* Do some stuff here */

    /* Start thread that will send a message */
    if(pthread_create(&thread_recv_id, &thread_attr, thread_recv_fd, NULL) == -1) {
        fprintf(stderr, "Failed to create thread, reason [ %s ]",
            strerror(errno));
            break;
        }
        printf("Start listening for receiving data'\n");

        /* Start thread to receive messages */
        if(pthread_create(&thread_send_id, &thread_attr, thread_send_fd, NULL) == -1) {
            fprintf(stderr, "Failed to create thread for receiving, reason [ %s ]",
                    strerror(errno));
            break;
        }

    /* Clean up threading properties */
    pthread_join(thread_send_id, NULL);
    pthread_join(thread_recv_id, NULL); <---- blocking here waiting for the recv thread to finish

    pthread_mutex_destroy(&mutex_queue);
    pthread_cond_destroy(&cond_queue);

    return 0;
}

sender thread

void *thread_send_fd()
{
        pthread_mutex_lock(&mutex_queue);
        if(send_fd((int)fd) == FALSE) {
            /* Just continue to send another item */
            continue;
        }
        /* Signal the waiting thread to remove the item that has been sent */
        pthread_cond_signal(&cond_queue);

        pthread_mutex_unlock(&mutex_queue);
}

receiver thread

void *thread_recv_fd()
{
    while(is_receiving()) {
        pthread_mutex_lock(&mutex_queue);

        /* Wait for an item to be sent on the queue */
        pthread_cond_wait(&cond_queue, &mutex_queue); <---- waiting here

        queue_remove();
        pthread_mutex_unlock(&mutex_queue);
    }

    pthread_exit(NULL);
}