- /*
- * 线程同步——互斥量
- * 创建两个线程，使用互斥量使任一时刻只有一个线程对全局变量进行
- 操作
- * Lzy 2011-6-19
- */
- #include <stdio.h>
- #include <stdlib.h>
- #include <pthread.h>
- pthread_mutex_t mutex; /* 定义
- 互斥量 */
- int x;
- /* 定义全局变量 */
- void thread1(void) /* 定义线程1运
- 行的函数，其功能是对全局变量x进行逐减操作 */
- {
- while(x>0)
- {
- pthread_mutex_lock(&mutex); /* 对互斥量进行
- 加锁操作 */
- printf("Thread 1 is running : x=%d \n",x);
- x--;
- pthread_mutex_unlock(&mutex); /* 对互斥量进行
- 解锁操作 */
- sleep(1);
- }
- pthread_exit(NULL);
- }
- void thread2(void) /* 定义线程2运
- 行的函数，功能与thread2相同 */
- {
- while(x>0)
- {
- pthread_mutex_lock(&mutex); /* 对互斥量进行
- 加锁操作 */
- printf("Thread 2 is running : x=%d \n",x);
- x--;
- pthread_mutex_unlock(&mutex); /* 对互斥量进行
- 解锁操作 */
- sleep(1);
- }
- pthread_exit(NULL);
- }
- int main(void)
- {
- pthread_t id1,id2;
- /* 定义线程的标识符 */
- int ret;
- ret = pthread_mutex_init(&mutex,NULL); /* 对互斥量进行
- 初始化，这里使用默认的属性 */
- if(ret != 0)
- {
- printf ("Mutex initialization failed.\n"); /* 如果
- 初始化失败，打印错误信息 */
- exit (1);
- }
- x=10;
- /* 对全局变量赋初值 */
- ret = pthread_create(&id1, NULL, (void *)&thread1, NULL);
- /* 创建线程1 */
- if(ret != 0)
- {
- printf ("Thread1 creation failed.\n");
- exit (1);
- }
- ret = pthread_create(&id2, NULL, (void *)&thread2, NULL);
- /* 创建线程2 */
- if(ret != 0)
- {
- printf ("Thread2 creation failed.\n");
- exit (1);
- }
- pthread_join(id1, NULL); /*线程
- 合并 */
- pthread_join(id2, NULL);
- return (0);
- }
- /*
- * 线程同步
- * ——读写锁
- * 只要没有进程持有某个给定的读写锁用于写，那么任意数目的
- 线程都可持有该读写锁用于读
- * 仅当没有线程持有某个给定的读写锁用于读或写，才能分配该
- 读写锁用于写。
- * Lzy 2011-6-19
- */
- #include <stdio.h>
- #include <stdlib.h>
- #include <pthread.h>
- int product = 0; //定义全局变量
- pthread_rwlock_t rwlock = PTHREAD_RWLOCK_INITIALIZER; //静态
- 初始化读写锁
- void * threadRead(void * arg) //线程函数读
- {
- int cnt = 0;
- while(cnt++ < 100)
- {
- pthread_rwlock_rdlock(&rwlock); //读锁
- printf("Read: product = %d\n", product);
- pthread_rwlock_unlock(&rwlock); //解锁
- sleep(1);
- }
- }
- void * tidProduce(void * arg) //线程函数写 加1
- {
- int cnt = 0;
- while(cnt++ < 100)
- {
- pthread_rwlock_wrlock(&rwlock); //写锁
- product++;
- printf("Produce: product = %d\n", product);
- pthread_rwlock_unlock(&rwlock); //解锁
- sleep(1);
- }
- }
- void * threadConsume(void * arg) //线程函数写 减1
- {
- int cnt = 0;
- while(cnt++ < 100)
- {
- pthread_rwlock_wrlock(&rwlock); //写锁
- product--;
- printf("Consume: product = %d\n", product);
- pthread_rwlock_unlock(&rwlock); //解锁
- sleep(2);
- }
- }
- int main(void)
- {
- int i;
- pthread_t tid[10], tidconsume, tidproduce;
- for(i = 0; i < 2; i++)
- {
- if(pthread_create(&tid[i], NULL, threadRead,
- NULL))
- {
- printf("pthread_create error\n");
- exit(0);
- }
- }
- if(pthread_create(&tidproduce, NULL, tidProduce, NULL))
- {
- printf("pthread_create error\n");
- exit(0);
- }
- if(pthread_create(&tidconsume, NULL, threadConsume,
- NULL))
- {
- printf("pthread_create error\n");
- exit(0);
- }
- pthread_exit(NULL); //等待所有线程结束
- return 0;
- }