#include<stdio.h> #include<pthread.h> #include<string.h> #include<sys/time.h> #define MAX 20 //定义三个线程共同完成计数任务 pthread_t thread[3]; pthread_mutex_t mut;//定义互斥锁变量 int num=0; int i; void *thread1(){ printf("thread1:im thread 1"); for(i=0;i<MAX;i++){ printf("thread1:num=%d \n",num); pthread_mutex_lock(&mut); num++; pthread_mutex_unlock(&mut); sleep(2); } pthread_exit(NULL); } void *thread2(){ printf("thread1:im thread 1"); for(i=0;i<MAX;i++){ printf("thread1:num=%d \n",num); pthread_mutex_lock(&mut); num++; pthread_mutex_unlock(&mut); sleep(2); } pthread_exit(NULL); } void *thread3(){ printf("thread1:im thread 1"); for(i=0;i<MAX;i++){ printf("thread1:num=%d \n",num); pthread_mutex_lock(&mut); num++; pthread_mutex_unlock(&mut); sleep(2); } pthread_exit(NULL); } void main(){ pthread_mutex_init(&mut,NULL);//使用默认属性来初始化互斥锁 pthread_create(&thread[0],NULL,thread1,NULL);//创建线程并没有运行 pthread_create(&thread[1],NULL,thread1,NULL); pthread_create(&thread[2],NULL,thread1,NULL); pthread_join(thread[0],NULL);//把线程1加入等待开始执行 pthread_join(thread[1],NULL); pthread_join(thread[2],NULL); }
时间: 2024-10-09 19:46:12