一、為什么要使用一次性初始化
? ? 有些事需要且只能執行一次（比如互斥量初始化）。通常當初始化應用程序時，可以比較容易地將其放在main函數中。但當你寫一個庫函數時，就不能在main里面初始化了，你可以用靜態初始化，但使用一次初始（pthread_once_t）會比較容易些。

二、如何進行一次性初始化
? ? 1、首先要定義一個pthread_once_t變量，這個變量要用宏PTHREAD_ONCE_INIT初始化。然后創建一個與控制變量相關的初始化函數：

? ? pthread_once_t once_control = PTHREAD_ONCE_INIT;void init_routine（）{//初始化互斥量//初始化讀寫鎖......}

? ? 2、接下來就可以在任何時刻調用pthread_once函數
? ? int pthread_once(pthread_once_t* once_control, void (*init_routine)(void));
? ? 功能：本函數使用初值為PTHREAD_ONCE_INIT的once_control變量保證init_routine()函數在本進程執行序列中僅執行一次。在多線程編程環境下，盡管pthread_once()調用會出現在多個線程中，init_routine()函數僅執行一次，究竟在哪個線程中執行是不定的，是由內核調度來決定。
? ? 3、Linux Threads使用互斥鎖和條件變量保證由pthread_once()指定的函數執行且僅執行一次。實際"一次性函數"的執行狀態有三種：
? ? ? ? NEVER（0）、IN_PROGRESS（1）、DONE （2），用once_control來表示pthread_once()的執行狀態：
? ? ?1）、如果once_control初值為0，那么 pthread_once從未執行過，init_routine()函數會執行。
? ? 2）、如果once_control初值設為1，則由于所有pthread_once()都必須等待其中一個激發"已執行一次"信號， 因此所有pthread_once ()都會陷入永久?的等待中，init_routine()就無法執行
? ? 3）、如果once_control設為2，則表示pthread_once()函數已執行過一次，從而所有pthread_once()都會立即 ? 返回，init_routine()就沒有機會執行，當pthread_once函數成功返回，once_control就會被設置為2。四、實例
1、一次性初始化的驗證

/*DATE: ? ? ? ? ? ?2015-4-15*AUTHOR: ? ? ? ?DDDDD*DESCRIPTION: ? ?一次性初始化int pthread_once(pthread_once_t* once_control, void (*init_routine)(void));如果once_control為0，init_routine()就會執行pthread_once()成功返回之后，once_control會變為2*/#include "apue.h"pthread_once_t once = 2; pthread_t tid;void thread_init() {printf("I'm in thread 0x%x\n", tid);}void *thread_fun1(void *arg) {tid = pthread_self();printf("I'm thread 0x%x\n", tid);printf("once is %d\n", once);pthread_once(&once, thread_init);printf("once is %d\n", once);return NULL; }void *thread_fun2(void *arg) {sleep(2);tid = pthread_self();printf("I'm thread 0x%x\n", tid);pthread_once(&once, thread_init);return NULL; }int main() {pthread_t tid1, tid2;int err;err = pthread_create(&tid1, NULL, thread_fun1, NULL);if(err != 0){printf("create new thread 1 failed\n");return ;}err = pthread_create(&tid2, NULL, thread_fun2, NULL);if(err != 0){printf("create new thread 1 failed\n");return ;}pthread_join(tid1, NULL);pthread_join(tid2, NULL);return 0; }

2、將互斥量的初始化，使用pthread_once來實現
?

/*DATA: ? ? ? ? ? ?2015-4-20*AUTHOR; ? ? ? ?WJ*DESCRIPTION: ? ?使用多線程對一個隊列進行增加和減少，增加操作是一個線程，刪除操作是一個線程* ? ?*/ #include "apue.h"pthread_mutex_t mutex; pthread_once_t once = PTHREAD_ONCE_INIT;struct queue{int len;int write_pos;int read_pos;int data[50]; };//互斥量初始化函數 void mutex_init() {int err;err = pthread_mutex_init(&mutex, NULL);if(err){printf("mutex init failed\n");return;} }//隊列初始化 struct queue *queue_init() {struct queue *que;//申請內存que = (struct queue *)malloc(sizeof(struct queue));if(que ==NULL){printf("malloc failed\n");return;}//初始化que->len = 0;que->write_pos = 0;que->read_pos = 0;return que; }void queue_destroy(struct queue *que) {//銷毀互斥量和quepthread_mutex_destroy(&mutex);free(que); }void *queue_add(void *arg) {//對互斥量進行一次性初始化pthread_once(&once, mutex_init);struct queue *que = (struct queue *)arg;int buf=0;while(buf<50){pthread_mutex_lock(&mutex);que->data[que->write_pos] = buf;que->write_pos ++;que->len ++;buf++;printf("write data %d to queue\n", que->data[que->write_pos -1]);pthread_mutex_unlock(&mutex);sleep(1);} }void *queue_del(void *arg) {// ? ?對互斥量進行一次性初始化pthread_once(&once, mutex_init);struct queue *que = (struct queue *)arg;int buf=0;while(1){sleep(2);pthread_mutex_lock(&mutex);buf = que->data[que->read_pos];que->read_pos ++;if(que->len -- == 0){printf("queue is empty\n");return;}buf++;printf("read data %d from queue\n", que->data[que->read_pos -1]);pthread_mutex_unlock(&mutex);} }int main() {pthread_t tid1, tid2;int err;struct queue *que;//隊列初始化que = queue_init();err = pthread_create(&tid1, NULL, queue_add, (void *)que);if(err){printf("create add thread failed\n");queue_destroy(que);return;}err = pthread_create(&tid2, NULL, queue_del, (void *)que);if(err){printf("create del thread failed\n");queue_destroy(que);return;}//等待增加和刪除操作完成pthread_join(tid1, NULL);pthread_join(tid2, NULL);//銷毀queue_destroy(que); }

?

總結

以上是生活随笔為你收集整理的linux下线程的一次性初始化的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。