IOS多线程 之 线程安全，线程同步，读写安全详解
什么是线程不安全和线程安全？
-
线程不安全：
是指不提供加锁机制保护，有可能出现多个线程先后更改数据造成所得到的数据是脏数据。如下图：
image.png
-
线程安全：
指多个线程在执行同一段代码的时候采用加锁机制，使每次的执行结果和单线程执行的结果都是一样的，不存在执行程序时出现意外结果。如下图：
image.png
如何解决线程不安全？
使用线程同步技术（同步，就是协同步调，按预定的先后次序进行）
常见的线程同步技术是：加锁
举例：
假设售票系统有15张票，A，B，C同时来买票，如果是线程不安全，那么可能售票系统可能出现15-1去同时执行的情况，最终结果是A，B，C都买完后剩下13张票，而不是12张。
/**
卖1张票
*/
- (void)saleTicket
{
int oldTicketsCount = self.ticketsCount;
sleep(.2);
oldTicketsCount--;
self.ticketsCount = oldTicketsCount;
NSLog(@"还剩%d张票 - %@", oldTicketsCount, [NSThread currentThread]);
}
/**
卖票演示
*/
- (void)ticketTest
{
self.ticketsCount = 15;
dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
dispatch_async(queue, ^{
[self saleTicket];
});
dispatch_async(queue, ^{
[self saleTicket];
});
dispatch_async(queue, ^{
[self saleTicket];
});
}
打印结果为：
2020-03-26 15:29:49.638680+0800 Interview03-安全隐患[12657:281738] 还剩14张票 - <NSThread: 0x600001cd03c0>{number = 9, name = (null)}
2020-03-26 15:29:49.638694+0800 Interview03-安全隐患[12657:281709] 还剩14张票 - <NSThread: 0x600001c9db00>{number = 7, name = (null)}
2020-03-26 15:29:49.638800+0800 Interview03-安全隐患[12657:281458] 还剩13张票 - <NSThread: 0x600001cbaf40>{number = 3, name = (null)}
要解决以上线程不安全的问题，就需要给每个线程加同一把锁。
锁又分为自旋锁、互斥锁、递归锁、读写锁
-
自旋锁：
自旋锁是一种特殊的互斥锁，当资源被加锁后，其它线程想要再次加锁，此时该线程不会被阻塞睡眠而是陷入循环等待状态（不能再做其它事情），循环检查资源持有者是否已经释放了资源，这样做的好处是减少了线程从睡眠到唤醒的资源消耗，但会一直占用CPU资源。适用于资源的锁被持有的时间短，而不希望在线程的唤醒上花费太多资源的情况。 -
互斥锁：
一个线程获得资源的使用权后就会将改资源加锁，使用完后会将其解锁，所以在使用过程中有其它线程想要获取该资源的锁，那么它就会被阻塞陷入睡眠状态，直到该资源被解锁才会别唤醒，如果被阻塞的资源不止一个，那么它们都会被唤醒，但是获得资源使用权的是第一个被唤醒的线程，其它线程又陷入沉睡。 -
递归锁：
同一个线程可以多次获得该资源锁，别的线程必须等待该线程释放所有次数的锁才能获得。 -
读写锁:
读写锁拥有读状态加锁、写状态加锁、不加锁三种状态。只有一个线程可以占有写状态的锁，但可以多个线程同时占有读状态锁，这也是它可以实现高并发的原因。当其处于写状态锁下，任何想要尝试获得锁的线程都会被阻塞，直到写状态锁被释放；如果是处于读状态锁下，允许其它线程获得它的读状态锁，但是不允许获得它的写状态锁，当读写锁感知到有线程想要获得写状态锁时，便会阻塞其后所有想要获得读状态锁的线程。所以读写锁非常适合资源的读操作远多于写操作的情况。
有以下10种加锁方案：
注意：在不同的线程中加锁，必须是同一把锁。
-
OSSpinLock：需导入头文件
#import <libkern/OSAtomic.h>，是自旋锁。
目前已经不再安全，可能会出现优先级反转问题。(如果等待锁的线程的优先级较高，它会一直占用CPU资源，优先级低的线程就无法释放锁)//初始化锁 OSSpinLock lock = OS_SPINLOCK_INIT; //加锁 OSSpinLockLock(&lock); //解锁 OSSpinLockUnlock(&lock); -
os_unfair_lock：需导入头文件
#import <os/lock.h>，是互斥锁。
用于取代不安全的OSSpinLock，从IOS10开始才支持，从底层调用看，等待os_unfair_lock锁的线程会处于休眠状态，并非忙等。//初始化锁 os_unfair_lock lock = OS_UNFAIR_LOCK_INIT; //加锁 os_unfair_lock_lock(&lock); //解锁 os_unfair_lock_unlock(&lock); -
pthread_mutex_t：需导入头文件
#import <pthread.h>，是互斥锁。//申明mutex锁 pthread_mutex_t mutex; //声明mutex锁的属性 pthread_mutexattr_t attr; //初始化属性attr pthread_mutexattr_init(&attr); //设置锁属性的类型 /* 参数说明 * * 第一个参数pthread_mutexattr_t：mutex锁属性attr对象的地址 * 第二个参数：锁的类型 #define PTHREAD_MUTEX_NORMAL 0 //默认锁，也就是”互斥锁“ #define PTHREAD_MUTEX_ERRORCHECK 1 //错误锁 #define PTHREAD_MUTEX_RECURSIVE 2 //递归锁 #define PTHREAD_MUTEX_DEFAULT PTHREAD_MUTEX_NORMAL */ pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_NORMAL); //初始化锁 /* 参数说明 * * 第一个参数pthread_mutex_t：mutex锁对象的地址 * 第二个参数pthread_mutexattr_t：mutex锁属性attr对象的地址。该参数可以传NULL，为默认属性PTHREAD_MUTEX_DEFAULT，”互斥锁“ */ pthread_mutex_init(&mutex, &attr); //销毁mutex锁的属性 pthread_mutexattr_destroy(&attr); //加锁 pthread_mutex_lock(&mutex); //解锁 pthread_mutex_unlock(&mutex); //销毁锁 pthread_mutexattr_destroy(&mutex);扩展：
pthread_cond_t条件锁：配合pthread_mutex_t实现//初始化条件锁 pthread_cond_t cond; pthread_cond_init(&cond, NULL); //条件等待，当线程调用该函数，然后阻塞当前线程进入休眠并解锁。 pthread_cond_wait(&cond, &mutex); //条件唤醒，当线程中调用该函数，等到该调用线程解锁后，然后h就唤醒前面休眠的线程，并给唤醒线程加锁。 //唤醒一个等待该条件的线程 pthread_cond_signal(&cond); //唤醒所有等待该条件的线程 pthread_cond_broadcast(&cond); //销毁条件 pthread_cond_destroy(&cond); -
NSLock：对pthread_mutex_t的锁封装。
//初始化锁 NSLock *lock = [[NSLock alloc] init]; //加锁 [lock lock]; //解锁 [lock unlock]; -
NSRecursiveLock:：对pthread_mutex_t的的递归锁封装。
//初始化锁 NSRecursiveLock *recursiveLock = [[NSRecursiveLock alloc] init]; //加锁 [recursiveLock lock]; //解锁 [recursiveLock unlock]; -
NSCondition：对pthread_mutex_t的cond条件和mutex锁封装。
//初始化锁 NSCondition *cond = [[NSCondition alloc] init]; //加锁 [cond lock]; //条件等待 [cond wait]; //唤醒条件等待 //唤醒一个条件等待 [cond signal]; //唤醒所有条件等待 [cond broadcast]; //解锁 [cond unlock]; -
NSConditionLock：对pthread_mutex_的cond条件和mutex锁封装。会根据内部存储的条件condition的值，进行加锁。
//初始化锁 NSConditionLock *condLock = [[NSConditionLock alloc] initWithCondition:1]; //加锁 [condLock lockWhenCondition:1]; //解锁 [condLock unlockWithCondition:2]; //加锁 [condLock lockWhenCondition:2]; //解锁 [condLock unlock]; -
在同步串行队列中开启子线程执行任务。
dispatch_sync(dispatch_queue_create("sertal", DISPATCH_QUEUE_SERIAL), ^{ dispatch_async(dispatch_get_global_queue(0, 0), ^{ //执行操作 }); }); -
使用信号量dispatch_semaphore_t控制线程最大并发数量：
// 信号量的初始值 int value = 1; //初始化信号量 dispatch_semaphore_t semaphore = dispatch_semaphore_create(value); // 如果信号量的值<=0，当前线程就进入休眠等待（直到信号量的值>0）。 // 如果信号量的值>0，就减1，然后往下执行后面的代码。 dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); // 让信号量的值加1 dispatch_semaphore_signal(semaphore); -
@synchronized：是封装了mutex的递归锁。
@synchronized([self class]) { //执行操作 }
IOS线程同步方案性能比较：
从高到低：
os_unfair_lock
OSSpinLock
dispatch_semaphore
pthread_mutex
dispatch_queue(DISPATCH_QUEUE_SERIAL)
NSLock
NSCondition
pthread_mutex(recursive)
NSRecursiveLock
NSConditionLock
@synchronized
多线程文件读写安全，多读单写：
-
使用读写锁pthread_rwlock_t：是“互斥锁”。
//声明读写锁 pthread_rwlock_t rwlock; //初始化读写锁 pthread_rwlock_init(&rwlock, NULL); //读的加锁 pthread_rwlock_rdlock(&rwlock); //读的解锁 pthread_rwlock_unlock(&rwlock); //写的加锁 pthread_rwlock_wrlock(&rwlock); //写的解锁 pthread_rwlock_unlock(&rwlock); //销毁锁 pthread_rwlock_destroy(&rwlock); -
异步函数dispatch_async进行读的操作和异步栅栏dispatch_barrier_async进行写的操作：读写操作必须保证在同一个手动创建的并发队列中。
//必须手动创建并发队列 dispatch_queue_t queue = dispatch_queue_create("concurrent", DISPATCH_QUEUE_CONCURRENT); //异步h函数执行读的操作 dispatch_async(queue, ^{ //读的操作 }); //异步栅栏函数进行写的操作，队列必须是手动创建的全局并发队列。 //如果不是，传入的是串行队列或者全局并发队列，异步栅栏会失效，效果等同于异步函数dispatch_async dispatch_barrier_async(queue, ^{ //写的操作 });
