在C語言中,pthread_t
是一個用于表示線程的數據類型
#include<stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <unistd.h>
int shared_data = 0;
pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
void *producer(void *arg) {
int i;
for (i = 0; i < 10; i++) {
pthread_mutex_lock(&lock);
shared_data++;
printf("Producer: %d\n", shared_data);
pthread_mutex_unlock(&lock);
sleep(1);
}
return NULL;
}
void *consumer(void *arg) {
int i;
for (i = 0; i < 10; i++) {
pthread_mutex_lock(&lock);
printf("Consumer: %d\n", shared_data);
shared_data--;
pthread_mutex_unlock(&lock);
sleep(1);
}
return NULL;
}
int main() {
pthread_t producer_thread, consumer_thread;
// 創建生產者線程
if (pthread_create(&producer_thread, NULL, producer, NULL) != 0) {
perror("Failed to create producer thread");
exit(1);
}
// 創建消費者線程
if (pthread_create(&consumer_thread, NULL, consumer, NULL) != 0) {
perror("Failed to create consumer thread");
exit(1);
}
// 等待線程完成
pthread_join(producer_thread, NULL);
pthread_join(consumer_thread, NULL);
// 銷毀互斥鎖
pthread_mutex_destroy(&lock);
return 0;
}
這個示例展示了如何使用 pthread_t
和互斥鎖實現線程間通信。生產者線程和消費者線程都可以訪問共享數據 shared_data
,但是通過使用互斥鎖,我們確保了在任何時候只有一個線程可以訪問該數據。