如何实现以下场景,“多读单写”,经常用于文件等数据的读写操作
- 同一时间,只能有1个线程进行写的操作
- 同一时间,允许有多个线程进行读的操作
- 同一时间,不允许既有写的操作,又有读的操作
iOS中的实现方案有:
1. pthread_rwlock: 读写锁
2. dispatch_barrier_async: 异步栅栏调用
pthread_rwlock:读写锁
等待锁的线程会进入休眠
#import <pthread.h> // 导入头文件
@interface ViewController ()
@property (nonatomic ,assign) pthread_rwlock_t lock; // 定义一个锁属性
@end
@implementation ViewController
- (void)viewDidLoad {
[super viewDidLoad];
// 初始化锁
pthread_rwlock_init(&_lock, NULL);
}
// 读取数据的方法
- (void)read
{
// 读-加锁
pthread_rwlock_rdlock(&_lock);
// 读取数据的代码
NSLog(@"读取数据%s", __func__);
// 读完-解锁
pthread_rwlock_unlock(&_lock);
}
// 写入数据的方法
- (void)write
{
// 写-加锁
pthread_rwlock_wrlock(&_lock);
// 写入数据的代码
NSLog(@"写入数据%s", __func__);
// 写完-解锁
pthread_rwlock_unlock(&_lock);
}
- (void)dealloc
{
// 用完销毁锁
pthread_rwlock_destroy(&_lock);
}
其中的方法如下图
截屏2020-08-06 上午10.27.21.png
dispatch_barrier_async:异步栅栏调用
- 这个函数传入的并发队列必须是自己通过dispatch_queue_create创建的
- 如果传入的是一个串行或是一个全局的并发队列,那这个函数便等同于dispatch_async函数的效果
/** 异步栅栏调用的并发队列 */
@property (nonatomic, strong) dispatch_queue_t queue;
// 创建队列,必须是自己创建的队列,不能是全局的并发队列
_queue = dispatch_queue_create("rwqueue", DISPATCH_QUEUE_CONCURRENT);
// 异步读取
dispatch_async(_queue, ^{
// 读取的代码
});
// 栅栏调用写入,这样就能保证线程安全的写,并且不能有其他线程调用
dispatch_barrier_async(_queue, ^{
// 写入的代码
});
网友评论