中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

c++ pthread線程同步怎么做

c++
小樊
83
2024-06-25 16:27:30
欄目: 編程語言

在C++中使用pthread庫來創建線程進行同步,可以使用互斥鎖(mutex),條件變量(condition variable),信號量(semaphore)等機制來實現線程同步。

  1. 互斥鎖(mutex):互斥鎖可以用來保護共享資源,只有當一個線程獲得了互斥鎖之后才能對共享資源進行操作,其他線程需要等待該線程釋放互斥鎖之后才能繼續執行。
#include <pthread.h>

pthread_mutex_t mutex;

void* thread_func(void* arg) {
    pthread_mutex_lock(&mutex);
    // critical section
    pthread_mutex_unlock(&mutex);
    return NULL;
}

int main() {
    pthread_t thread;
    pthread_mutex_init(&mutex, NULL);
    pthread_create(&thread, NULL, thread_func, NULL);
    pthread_mutex_destroy(&mutex);
    pthread_join(thread, NULL);
    return 0;
}
  1. 條件變量(condition variable):條件變量可以用來在某個條件滿足時喚醒等待的線程,配合互斥鎖一起使用可以實現線程的等待和喚醒。
#include <pthread.h>

pthread_mutex_t mutex;
pthread_cond_t cond;

void* thread_func(void* arg) {
    pthread_mutex_lock(&mutex);
    pthread_cond_wait(&cond, &mutex);
    // do something
    pthread_mutex_unlock(&mutex);
    return NULL;
}

int main() {
    pthread_t thread;
    pthread_mutex_init(&mutex, NULL);
    pthread_cond_init(&cond, NULL);
    pthread_create(&thread, NULL, thread_func, NULL);
    pthread_cond_signal(&cond);
    pthread_join(thread, NULL);
    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond);
    return 0;
}
  1. 信號量(semaphore):信號量可以用來控制對共享資源的訪問,通過對信號量的操作來進行線程同步。
#include <pthread.h>
#include <semaphore.h>

sem_t semaphore;

void* thread_func(void* arg) {
    sem_wait(&semaphore);
    // do something
    sem_post(&semaphore);
    return NULL;
}

int main() {
    pthread_t thread;
    sem_init(&semaphore, 0, 1);
    pthread_create(&thread, NULL, thread_func, NULL);
    pthread_join(thread, NULL);
    sem_destroy(&semaphore);
    return 0;
}

以上是使用互斥鎖,條件變量和信號量來實現線程同步的示例代碼,根據具體的需求和場景選擇合適的同步機制來保證線程安全。

0
桐庐县| 成安县| 屏东市| 高陵县| 兴山县| 光山县| 阿尔山市| 天峻县| 永善县| 庐江县| 错那县| 嘉祥县| 新兴县| 游戏| 宁城县| 宁陵县| 腾冲县| 望都县| 文水县| 博爱县| 黔江区| 老河口市| 都匀市| 德格县| 廉江市| 庆元县| 泸溪县| 衡山县| 英山县| 襄城县| 抚远县| 军事| 古浪县| 石棉县| 平阳县| 巴塘县| 临海市| 红安县| 鄂伦春自治旗| 启东市| 丹棱县|