#include
#include
#include
// 定义互斥锁
pthread_mutex_t mutex;
// 线程函数
void *thread_func(void *arg) {
// 加锁
pthread_mutex_lock(&mutex);
// 访问共享资源
printf("Thread %ld is accessing the shared resource...\n", pthread_self());
// 解锁
pthread_mutex_unlock(&mutex);
return NULL;
}
int main() {
// 初始化互斥锁
pthread_mutex_init(&mutex, NULL);
// 创建多个线程
pthread_t threads[5];
for (int i = 0; i < 5; i++) {
pthread_create(&threads[i], NULL, thread_func, NULL);
}
// 等待所有线程结束
for (int i = 0; i < 5; i++) {
pthread_join(threads[i], NULL);
}
// 销毁互斥锁
pthread_mutex_destroy(&mutex);
return 0;
}
在这个例子中,我们定义了一个互斥锁 mutex,并在每个线程的函数中通过 pthread_mutex_lock 和 pthread_mutex_unlock 函数对互斥锁进行加锁和解锁操作。这样,当一个线程在访问共享资源时,其他线程必须等待该线程释放锁才能进行访问,从而保证了线程安全。