原來總是用互斥鎖(MUTEX)和環境變量(cond)去控制線程的通信,用起來挺麻煩的,用信號量(SEM)來通信控制就方便多了!
用到信號量就要包含semaphore.h頭文件。
可以用sem_t類型來聲明一個型號量。
用int sem_init(sem_t *sem, int pshared, unsigned int value)函數來初始化型號量,第一個參數就是用sem_t聲明的信號量,第二變量如果為0,表示這個信號量只是當前進程中的型號量,如果不為0,這個信號量可能可以在兩個進程中共享。第三個參數就是初始化信號量的多少值。
sem_wait(sem_t *sem)函數用於接受信號,當sem>0時就能接受到信號,然後將sem--;
sem_post(sem_t *sem)函數可以增加信號量。
sem_destroy(sem_t *sem)函數用於解除信號量。
以下是一個用信號控制的一個簡單的例子。
- #include <stdio.h>
- #include <semaphore.h>
- #include <pthread.h>
- sem_t sem1, sem2;
-
- void *thread1(void *arg)
- {
- sem_wait(&sem1);
- setbuf(stdout,NULL);//這裡必須注意,由於下面輸出"hello"中沒有‘\n’符,所以可能由於輸出緩存已滿,造成輸不出東西來,所以用這個函數把輸出緩存清空
- printf("hello ");
- sem_post(&sem2);
- }
-
- void *thread2(void *arg)
- {
- sem_wait(&sem2);
- printf("world!\n");
- }
-
- int main()
- {
- pthread_t t1, t2;
-
- sem_init(&sem1,0,1);
- sem_init(&sem2,0,0);
-
- pthread_create(&t1,NULL,thread1,NULL);
- pthread_create(&t2,NULL,thread2,NULL);
-
- pthread_join(t1,NULL);
- pthread_join(t2,NULL);
-
- sem_destroy(&sem1);
- sem_destroy(&sem2);
-
- return 0;
- }
程序的實現是控制先讓thread1線程打印"hello "再讓thread2線程打印"world!".