int pthread_mutex_destroy(pthread_mutex_t *mutex)；

互斥量加鎖和解鎖

int pthread_mutex_lock(pthread_mutex_t *mutex);
int pthread_mutex_unlock(pthread_mutex_t *mutex);
返回值:成功返回0,失敗返回錯誤號

調用 pthread_lock是，可能會遇到以下情況

互斥量處于未上鎖狀態，該函數會講把互斥量鎖定返回成功

如何發起函數調用時，其他線程已鎖定互斥量，沒有競爭到互斥量資源，此時pthread_lock調用會陷入阻塞，直到互斥量解鎖

修該上面的售票代碼

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <sched.h>
int ticket = 100;
pthread_mutex_t mutex;
void *route(void *arg)
{
char *id = (char*)arg;
while ( 1 ) {
pthread_mutex_lock(&mutex);if ( ticket > 0 ) {
usleep(1000);
printf("%s sells ticket:%d\n", id, ticket);
ticket--;
pthread_mutex_unlock(&mutex);
// sched_yield(); 放棄CPU
} 
else {
pthread_mutex_unlock(&mutex);
break;
}}}int main( void )
{
pthread_t t1, t2, t3, t4;
pthread_mutex_init(&mutex, NULL);
pthread_create(&t1, NULL, route, "thread 1");
pthread_create(&t2, NULL, route, "thread 2");
pthread_create(&t3, NULL, route, "thread 3");
pthread_create(&t4, NULL, route, "thread 4");
pthread_join(t1, NULL);
pthread_join(t2, NULL);
pthread_join(t3, NULL);
pthread_join(t4, NULL);
pthread_mutex_destroy(&mutex);
}

1-3 互斥量的封裝

test_4_22_httpserve/Mutex.h · liu xi peng/linux---ubuntu系統 - 碼云 - 開源中國

大家有興趣的可以點進去看一下

2.線程同步

2-1 條件變量

當一個線程互斥地訪問某個變量時，他可能發現在其他線程狀態改變之前他什么也做不了

例如?個線程訪問隊列時，發現隊列為空，它只能等待，只到其它線程將?個節點添加到隊列

2-2 同步概念與競態條件

#include <iostream>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
void *active( void *arg )
{
std::string name = static_cast<const char*>(arg);
while (true){
pthread_mutex_lock(&mutex);
pthread_cond_wait(&cond, &mutex);
std::cout << name << " 活動..." << std::endl;
pthread_mutex_unlock(&mutex);
}
}
int main( void )
{
pthread_t t1, t2;
pthread_create(&t1, NULL, active, (void*)"thread-1");
pthread_create(&t2, NULL, active, (void*)"thread-2");
sleep(3); // 可有可?，這?確保兩個線程已經在運?
while(true)
{
// 對?測試
// pthread_cond_signal(&cond); // 喚醒?個線程
pthread_cond_broadcast(&cond); // 喚醒所有線程
sleep(1);
}pthread_join(t1, NULL);
pthread_join(t2, NULL);
}