led行业网站源码,宜昌网站seo收费,浙江省建设建材工会网站,qq是腾讯旗下的吗目录
互斥锁的概念和使用
线程通信 - 互斥
互斥锁的创建和销毁
互斥锁的创建
互斥锁的销毁
互斥锁的使用
申请锁
释放锁 互斥锁的概念和使用
线程通信 - 互斥
临界资源#xff1a;
一次只允许一个任务#xff08;进程、线程#xff09;访问的共享资源#xff1b…目录
互斥锁的概念和使用
线程通信 - 互斥
互斥锁的创建和销毁
互斥锁的创建
互斥锁的销毁
互斥锁的使用
申请锁
释放锁 互斥锁的概念和使用
线程通信 - 互斥
临界资源
一次只允许一个任务进程、线程访问的共享资源
临界区
访问临界资源的代码
互斥机制
mutex互斥锁任务访问临界资源钱申请锁访问完后释放锁
互斥锁的创建和销毁
互斥锁的创建
两种方法创建互斥锁静态方式和动态方式
动态方式
int pthread_mutex_init(pthread_mutex_t *resttrict mutex, const pthread_mutexattr_t *restrict attr);
成功时返回0 失败时返回错误码
参数
pthread_mutex_t 定义一个互斥锁
mutex 指向要初始化的互斥锁对象
mutexattr 用于指定互斥锁属性如果为NULL测使用缺省属性。
man函数出现 No manual entry for pthread_mutex_xxx找不到pthread_mutex_xxx
解决办法apt-get install manpages-posix-dev
静态方式
pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER;
互斥锁的销毁
int pthread mutex destroy(pthread mutex_t *mutex)
在Linux中互斥锁并不占用任何资源因此LinuxThreads中的 pthread_mutex_destroy()
除了检查锁状态以外锁定状态则返回EBUSY没有其他动作。
互斥锁的使用
申请锁
int pthread_mutex_lock(pthread_mutex_t *mutex)
int pthread_mutex_trylock(pthread_mutex_t *mutex)
成功时返回0 失败时返回错误码
参数
mutex指向要初始化的互斥锁对象
pthread_mutex_lock 如果无法获得锁任务阻塞
pthread_mutex_trylock 如果无法获得锁返回EBUSY而不是挂起等待
释放锁
#include pthread.h
int pthread_mutex_unlock(pthread_mutex_t *mutex)成功时返回 0 失败时返回错误码
mutex 指向要初始化的互斥锁对象
问题实现多个线程写一个文件使用互斥锁
代码实现
#include pthread.h
#include stdio.h
#include unistd.h
#include string.hpthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER;FILE *fp;
void *func2(void *arg){pthread_detach(pthread_self());printf(This func2 thread\n);char str[]I write func2 line\n;char c;int i0;while(1){pthread_mutex_lock(mutex);while(istrlen(str)){c str[i];fputc(c,fp);usleep(1);i;}pthread_mutex_unlock(mutex);i0;usleep(1);}pthread_exit(func2 exit);}void *func(void *arg){pthread_detach(pthread_self());printf(This is func1 thread\n);char str[]You read func1 thread\n;char c;int i0;while(1){pthread_mutex_lock(mutex);while(istrlen(str)){c str[i];fputc(c,fp);i;usleep(1);}pthread_mutex_unlock(mutex);i0;usleep(1);}pthread_exit(func1 exit);
}int main(){pthread_t tid,tid2;void *retv;int i;fp fopen(1.txt,a);if(fpNULL){perror(fopen);return 0;}pthread_create(tid,NULL,func,NULL);pthread_create(tid2,NULL,func2,NULL);while(1){ sleep(1);} }读写锁的概念和使用
特性
对于写者写者使用写锁如果当前 没有读者也没有其他写者写者立即获得写锁否则写者将等待知道没有读者和其他写者
对于读者 读者使用读锁如果当前没有写者读者立即获取读锁否则读者等待知道没有写者。
注意
同一时刻只有一个线程可以获得写锁同一时刻可以有多个线程获得读锁。
读写锁处于写锁状态时所有试图对读写锁加锁的线程不管是读者试图加读锁还是写者试图加写锁都会被阻塞
读写锁处于读锁状态时有写者试图加写锁时之后的其他线程的读锁请求会被阻塞以避免写者长时间的不写锁
读写锁的创建
初始化一个读写锁
pthread_rwlock_init
读 锁定 读写定
pthread_rwlock_rdlock
非阻塞 读 锁定
pthread_rwlock_tryrdlock
写 锁定 读写锁
pthread_rwlock_wrlock
非阻塞 写 锁定
pthread_rwlock_trywrlock
解锁 读写锁
pthread_rwlock_unlock
释放 读写锁
pthread_rwlock_destroy
代码实现
#include pthread.h
#include stdio.h
#include unistd.h
#include string.hpthread_rwlock_t rwlock;FILE *fp;
void * read_func(void *arg){pthread_detach(pthread_self());printf(read thread\n);char buf[32]{0};while(1){//rewind(fp);pthread_rwlock_rdlock(rwlock);while(fgets(buf,32,fp)!NULL){printf(%d,rd%s\n,(int)arg,buf);usleep(1000);}pthread_rwlock_unlock(rwlock);sleep(1);}}void *func2(void *arg){pthread_detach(pthread_self());printf(This func2 thread\n);char str[]I write func2 line\n;char c;int i0;while(1){pthread_rwlock_wrlock(rwlock);while(istrlen(str)){c str[i];fputc(c,fp);usleep(1);i;}pthread_rwlock_unlock(rwlock);i0;usleep(1);}pthread_exit(func2 exit);}void *func(void *arg){pthread_detach(pthread_self());printf(This is func1 thread\n);char str[]You read func1 thread\n;char c;int i0;while(1){pthread_rwlock_wrlock(rwlock);while(istrlen(str)){c str[i];fputc(c,fp);i;usleep(1);}pthread_rwlock_unlock(rwlock);i0;usleep(1);}pthread_exit(func1 exit);
}int main(){pthread_t tid1,tid2,tid3,tid4;void *retv;int i;fp fopen(1.txt,a);if(fpNULL){perror(fopen);return 0;}pthread_rwlock_init(rwlock,NULL);pthread_create(tid1,NULL,read_func,1);pthread_create(tid2,NULL,read_func,2);pthread_create(tid3,NULL,func,NULL);pthread_create(tid4,NULL,func2,NULL);while(1){ sleep(1);} }死锁
概念
什么是死锁 避免方法
1、锁越少越好最好使用一把锁
2、调整好锁的顺序
