Linux等待线程全部停止的方法 (linux等待所有线程结束)
在Linux系统中，线程是可以进行并发操作的，多个线程可以同时运行，因此在编写多线程程序时，需要考虑线程的同步与状态控制。在多线程程序中，有时需要等待所有线程完成任务后再进行下一步操作，这就需要使用一些方法来实现线程的等待。
在本文中，将介绍几种Linux系统中等待线程停止的方法。
1.使用pthread_join函数
pthread_join函数用于等待指定的线程终止并回收其资源。当调用pthread_join函数时，主线程会被阻塞，直到指定的线程终止为止。
这个函数的调用格式如下所示：
“`
int pthread_join(pthread_t thread, void **retval);
“`
其中，参数thread是要等待的线程ID，参数retval是线程的返回值。如果不需要返回值，可以将retval设置为NULL。
在调用pthread_join函数时，如果指定的线程没有终止，则主线程会一直等待，直到被指定的线程终止。
使用pthread_join函数等待线程停止的示例代码如下：
“`c
#include
#include
#include
#include
void *thread_func(void *arg)
{
printf(“Sub thread is running\n”);
sleep(3);
printf(“Sub thread is exiting\n”);
pthread_exit(NULL);
}
int mn()
{
pthread_t tid;
int ret;
void *retval;
ret = pthread_create(&tid, NULL, thread_func, NULL);
if (ret != 0)
{
printf(“Create thread fled\n”);
return -1;
}
pthread_join(tid, &retval);
printf(“Mn thread is exiting\n”);
return 0;
}
“`
在这个示例中，主线程创建了一个子线程，子线程运行了3秒后就退出了。主线程调用pthread_join函数等待子线程终止，然后输出“Mn thread is exiting”并退出。
2.使用pthread_cond_wt函数配合pthread_cond_signal函数
pthread_cond_wt和pthread_cond_signal函数用于线程之间的条件等待和条件唤醒。使用条件变量可以实现线程的同步与等待。
pthread_cond_wt函数的原型如下所示：
“`c
int pthread_cond_wt(pthread_cond_t *cond, pthread_mutex_t *mutex);
“`
参数cond是条件变量，参数mutex是互斥锁。在调用pthread_cond_wt函数前，线程必须先获取到mutex的锁，然后才能调用pthread_cond_wt函数等待条件变量。
当条件变量被唤醒时，pthread_cond_wt函数会自动释放mutex锁，然后再返回，线程可以从等待状态中恢复。
pthread_cond_signal函数的原型如下所示：
“`c
int pthread_cond_signal(pthread_cond_t *cond);
“`
参数cond是条件变量，调用pthread_cond_signal函数后，等待在该条件变量上的一个线程会被唤醒。
pthread_cond_wt和pthread_cond_signal函数需要搭配使用，使用示例代码如下：
“`c
#include
#include
#include
#include
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
int done = 0;
void *thread_func(void *arg)
{
printf(“Sub thread is running\n”);
sleep(3);
printf(“Sub thread is exiting\n”);
pthread_mutex_lock(&mutex);
done = 1;
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
pthread_exit(NULL);
}
int mn()
{
pthread_t tid;
int ret;
void *retval;
ret = pthread_create(&tid, NULL, thread_func, NULL);
if (ret != 0)
{
printf(“Create thread fled\n”);
return -1;
}
pthread_mutex_lock(&mutex);
while (!done)
{
pthread_cond_wt(&cond, &mutex);
}
pthread_mutex_unlock(&mutex);
printf(“Mn thread is exiting\n”);
return 0;
}
“`
在这个示例中，主线程创建了一个子线程，子线程运行了3秒后就退出了。主线程使用互斥锁和条件变量等待子线程终止。当done变量的值被设置为1时，子线程会调用pthread_cond_signal函数唤醒一个等待在条件变量上的线程，主线程就可以从等待状态中恢复。
3.使用pthread_barrier_wt函数
pthread_barrier_wt函数用于等待一个屏障，屏障可以控制多个线程同时开始或结束。当等到所有线程到达屏障时，pthread_barrier_wt函数会返回，并允许所有线程同时开始或结束。
pthread_barrier_wt函数的原型如下所示：
“`c
int pthread_barrier_wt(pthread_barrier_t *barrier);
“`
参数barrier是屏障变量，在调用pthread_barrier_wt函数前，所有线程必须先调用pthread_barrier_init函数初始化屏障变量。
在多线程程序中使用pthread_barrier_wt函数等待线程停止的示例代码如下：
“`c
#include
#include
#include
#include
pthread_barrier_t barrier;
void *thread_func(void *arg)
{
printf(“Sub thread is running\n”);
sleep(3);
printf(“Sub thread is exiting\n”);
pthread_barrier_wt(&barrier);
pthread_exit(NULL);
}
int mn()
{
pthread_t tid1, tid2;
int ret;
void *retval;
pthread_barrier_init(&barrier, NULL, 2);
ret = pthread_create(&tid1, NULL, thread_func, NULL);
if (ret != 0)
{
printf(“Create thread1 fled\n”);
return -1;
}
ret = pthread_create(&tid2, NULL, thread_func, NULL);
if (ret != 0)
{
printf(“Create thread2 fled\n”);
return -1;
}
pthread_barrier_wt(&barrier);
printf(“Mn thread is exiting\n”);
return 0;
}
“`
在这个示例中，主线程创建了两个子线程，当所有子线程到达屏障时，主线程就可以从等待状态中恢复，并输出“Mn thread is exiting”并退出。在使用pthread_barrier_wt函数时，必须先调用pthread_barrier_init函数初始化屏障变量。
