/*
    使用多線程實(shí)現(xiàn)買票的案例。
    有3個(gè)窗口，一共是100張票。
*/
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
// 全局變量，所有的線程都共享這一份資源。
int tickets = 100;
void * sellticket(void * arg) {
    // 賣票
    while(tickets > 0) {
        usleep(6000);	//微秒
        printf("%ld 正在賣第 %d 張門票\n", pthread_self(), tickets);
        tickets--;
    }
    return NULL;
}
int main() {
    // 創(chuàng)建3個(gè)子線程
    pthread_t tid1, tid2, tid3;
    pthread_create(&tid1, NULL, sellticket, NULL);
    pthread_create(&tid2, NULL, sellticket, NULL);
    pthread_create(&tid3, NULL, sellticket, NULL);
    // 回收子線程的資源,默認(rèn)阻塞狀態(tài)
    pthread_join(tid1, NULL);
    pthread_join(tid2, NULL);
    pthread_join(tid3, NULL);
    // 設(shè)置線程分離。
    // pthread_detach(tid1);
    // pthread_detach(tid2);
    // pthread_detach(tid3);
    pthread_exit(NULL); // 退出主線程
    return 0;
}

/*
    互斥量的類型 pthread_mutex_t
    int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr);
        - 初始化互斥量
        - 參數(shù) ：
            - mutex ： 需要初始化的互斥量變量
            - attr ： 互斥量相關(guān)的屬性，NULL
        - restrict : C語(yǔ)言的修飾符，被修飾的指針，不能由另外的一個(gè)指針進(jìn)行操作。
            pthread_mutex_t *restrict mutex = xxx;
            pthread_mutex_t * mutex1 = mutex;	--不能這樣操作，有restrict關(guān)鍵詞
    int pthread_mutex_destroy(pthread_mutex_t *mutex);
        - 釋放互斥量的資源
    int pthread_mutex_lock(pthread_mutex_t *mutex);
        - 加鎖，阻塞的，如果有一個(gè)線程加鎖了，那么其他的線程只能阻塞等待
		- 成功返回 0
    int pthread_mutex_trylock(pthread_mutex_t *mutex);
        - 嘗試加鎖，如果加鎖失敗，不會(huì)阻塞，會(huì)直接返回。
    int pthread_mutex_unlock(pthread_mutex_t *mutex);
        - 解鎖
*/
#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
// 全局變量，所有的線程都共享這一份資源。
int tickets = 1000;
// 創(chuàng)建一個(gè)互斥量	--在全局區(qū)創(chuàng)建
pthread_mutex_t mutex;
void * sellticket(void * arg) {
    // 賣票
    while(1) {
        // 加鎖
        pthread_mutex_lock(&mutex);
        if(tickets > 0) {
            usleep(6000);
            printf("%ld 正在賣第 %d 張門票\n", pthread_self(), tickets);
            tickets--;
        }else {
            // 解鎖
            pthread_mutex_unlock(&mutex);
            break;
        }
        // 解鎖
        pthread_mutex_unlock(&mutex);
    }
    return NULL;
}
int main() {
    // 初始化互斥量
    pthread_mutex_init(&mutex, NULL);
    // 創(chuàng)建3個(gè)子線程
    pthread_t tid1, tid2, tid3;
    pthread_create(&tid1, NULL, sellticket, NULL);
    pthread_create(&tid2, NULL, sellticket, NULL);
    pthread_create(&tid3, NULL, sellticket, NULL);
    // 回收子線程的資源,阻塞
    pthread_join(tid1, NULL);
    pthread_join(tid2, NULL);
    pthread_join(tid3, NULL);
    pthread_exit(NULL); // 退出主線程
    // 釋放互斥量資源
    pthread_mutex_destroy(&mutex);
    return 0;
}