无限循环多线程

Question

我已经写了这个生产者/消费者问题解决方案。它似乎在工作，而不是无限循环。我的印象是，pthread\u exit（NULL） 会让它停止，但老实说，我已经迷路了。有人能告诉我如何阻止循环的正确方向吗？

#include<stdio.h>
#include<string.h>
#include<pthread.h>
#include<stdlib.h>
#include<unistd.h>
#include<iostream>
#include<semaphore.h>

#define BUFFSIZE 10

using namespace std;

int buffer[BUFFSIZE];
int size; //current buffer size
int n = 0, m = 0;

pthread_mutex_t Mutex = PTHREAD_MUTEX_INITIALIZER;

sem_t Available;
sem_t Buffer; //indicates if buffer is full

//----------------------------------------------------------------//

void *Consumers(void *argument)
{
    int con_id = *((int *) argument);
    while(1)
    {
        if(size == 0)
        {
            cout << "Queue is empty." << endl;
        }

        sem_wait(&Available);
        pthread_mutex_lock(&Mutex);

        size--;
        cout << "Con " << con_id << ": Product removed from buffer" << endl;
        //for(int i = 0; i < size; i++)
        //{
        //  cout << Buffer[i] << " ";
        //}
        cout << endl;
        pthread_mutex_unlock(&Mutex);
        sem_post(&Buffer);
    }
    return(NULL);
}

//----------------------------------------------------------------//

void *Producers(void *argument)
{
    int item = 8;
    int pro_id = *((int *) argument);

    while(1)
    {
        sem_wait(&Buffer);
        pthread_mutex_lock(&Mutex);
        //Buffer[size] = item;
        cout << "Item added" << endl;
        size++;
        pthread_mutex_unlock(&Mutex);
        sem_post(&Available);
    }
    return(NULL);
}

//----------------------------------------------------------------//

int main()
{

    cout << "Enter number of producers: " << endl;
    scanf("%d", &n);
    cout << "Enter number of consumers: " << endl;
    scanf("%d", &m);
    //get number of producers(int n), and consumers(int m)
    sem_init(&Available, 0, 0);
    sem_init(&Buffer, 0, BUFFSIZE);

    pthread_t *con = new pthread_t[m];
    int *thread_args_c = new int[m];
    for(int i = 0; i < n; i++)
    {
        thread_args_c[i] = i;
        pthread_create(&con[i], NULL, Consumers, (void*) &i);
    }

    pthread_t *pro = new pthread_t[n];
    int *thread_args_p = new int[n];
    for(int i = 0; i < n; i++)
    {
        thread_args_p[i] = i;
        pthread_create(&pro[i], NULL, Producers, (void*) &i);
        pthread_join(con[i], NULL);
    }

    pthread_exit(NULL);

}

Answer 1

循环不会停止，因为代码中没有实际退出循环的逻辑。

进程被卡住，因为pthread\u join会挂起调用线程，直到目标退出。请参阅pthread\u join文档

如果不关心实际终止线程并返回主线程，只需删除对pthread\u join的调用即可。进程应该终止，因为主线程已退出。

要真正正确终止循环，您需要设置一个内部或外部触发器。您可以在内部让循环在一定次数的迭代后退出。为此，您将执行而（x

您还可以使其更加复杂，并让主线程在外部向其他线程发出信号，表示它希望其他线程关闭。当您准备退出时，您可以让主线程设置一个（易失性）布尔值，并让其他线程中断基于它的循环。如果您关心退出的原子性，您需要使用锁来保护布尔值。

Answer 2

pthread_exit出现在main的末尾（并且完全不需要，因为main正在退出），但是您在线程中的无限循环永远不会让main到达这一点（因为您正在加入消费者线程）。

此外，您的创建和加入模型也很有意义——在创建了制作人之后加入消费者线程有什么意义？

最后，但不是租约，您未能加入生产者线程。