Swift线程安全详解-概念,三种锁,死锁,Atomic,synchronized

原创Blog,转载请注明出处
http://blog.csdn.net/hello_hwc?viewmode=list
我的stackoverflow

前言:最近app中的日历小概率的在currentCalendar这个方法崩溃,看了下call
tree。研究了下,是线程安全问题。这里,就系统性的总结下线程安全这部分。

之后的博客绝大部分源码会用Swift来写了。

一些资料

  1. objc.io上对应多线程这一章
  2. Apple thread safe

iOS中的线程

什么是线程?
线程是操作系统进行调度的最小单位,它被包含在进程中,是进程运作的实际单位。在单核系统中,按照时间片轮转的方式实现线程的并发执行,在多核系统中,能够真正实现线程同时执行。

iOS中与多线程相关的常用的有NSThread,GCD,NSOperationQueue.还有一个不常用,但是理解很重要的NSRunloop。

什么是线程安全?

当一段代码被多个线程执行,执行后的结果和多个线程依次执行后的结果一致,那么这段代码就是线程安全的。

再看看WIKI中的定义

A piece of code is thread-safe if it only manipulates shared data structures in a manner that guarantees safe execution by multiple threads at the same time.
一段代码在多个线程上调用,并且共享一段内存空间。如果代码能够安全执行,就是线程安全的。

举个例子

NSMutableArray不是线程安全的,那么以下代码就会小概率崩溃

let queue1 = dispatch_queue_create("com.test.queue1",DISPATCH_QUEUE_SERIAL)
        let queue2 = dispatch_queue_create("com.test.queue1",DISPATCH_QUEUE_SERIAL)
        dispatch_async(queue1) { () -> Void in
            for index in 1...500{
                self.emptyArray.addObject(NSNumber(integer: index))
            }
        }
        dispatch_async(queue2) { () -> Void in
            for index in 500...1000{
                self.emptyArray.addObject(NSNumber(integer: index))
            }
        }

运行的话,崩溃如图

错误Log

malloc: * error for object 0x7fb5804a9d40: pointer being freed was not allocated
* set a breakpoint in malloc_error_break to debug

注意,这种崩溃是小概率的,但是当用户量大的时候,就会知道小概率也是不可忽视的
这不会详细介绍NSMutableArray的背后实现原理,感兴趣的同学可以看看这篇文章

错误原因-抽象到malloc和free的问题

每次malloc会分配新的地址,然后free释放。有可能按照如图的方式malloc-malloc-free-free.这样同一个地址会free两次,也就crash了。类似的在ARC中release一个reference count为0的对象也会出错。

UIKit以及Fundation

事实上,大多数Cocoa提供的Api都不是线程安全的,尤其是与UI相关的UIKit,只能在主线程上操作。

在后台更新UI是很多开发者容易犯的错误

那么,为什么不把Cocoa的API写成线程安全的呢?Apple那么多天才工程师,难道解决不了吗?

答案很明显:为了执行效率,大多数的时候不需要并行的执行一段代码,而加上锁,递归锁之类的东西,执行效率会降低很多。需要线程安全的时候,开发者自己维护就可以了。

通常,不可变对象是线程安全的,可变对象不是线程安全的
以下Fundation对象是线程安全的,

意味着,你可以在多个线程中访问一个对象(读写),而不需要加锁

NSArray
NSAssertionHandler
NSAttributedString
NSCalendarDate
NSCharacterSet
NSConditionLock
NSConnection
NSData
NSDate
NSDecimal functions
NSDecimalNumber
NSDecimalNumberHandler
NSDeserializer
NSDictionary
NSDistantObject
NSDistributedLock
NSDistributedNotificationCenter
NSException
NSFileManager (in OS X v10.5 and later)
NSHost
NSLock
NSLog/NSLogv
NSMethodSignature
NSNotification
NSNotificationCenter
NSNumber
NSObject
NSPortCoder
NSPortMessage
NSPortNameServer
NSProtocolChecker
NSProxy
NSRecursiveLock
NSSet
NSString
NSThread
NSTimer
NSTimeZone
NSUserDefaults
NSValue
NSXMLParser
Object allocation and retain count functions
Zone and memory functions

以下对象不是线程安全的

NSArchiver
NSAutoreleasePool
NSBundle
NSCalendar
NSCoder
NSCountedSet
NSDateFormatter
NSEnumerator
NSFileHandle
NSFormatter
NSHashTable functions
NSInvocation
NSJavaSetup functions
NSMapTable functions
NSMutableArray
NSMutableAttributedString
NSMutableCharacterSet
NSMutableData
NSMutableDictionary
NSMutableSet
NSMutableString
NSNotificationQueue
NSNumberFormatter
NSPipe
NSPort
NSProcessInfo
NSRunLoop
NSScanner
NSSerializer
NSTask
NSUnarchiver
NSUndoManager

objc_sync_enter/objc_sync_exit

先看看文档,个人建议,遇到一个新的Api或者技术一定要先看看Apple的文档,别人的博客只是一个参考,很有可能别人博客的理解就是错的,当然也包括我的博客
objc_sync_enter

Begin synchronizing on ‘obj’. Allocates recursive pthread_mutex associated with ‘obj’ if needed.
这个和Objective C中的synchronized关键词类似。对某一个对象加互斥锁,保证线程一在访问对象的过程中,线程二以及其他线程不能访问。(简单来说互斥锁允许同一个线程lock一个对象两次,而不会死锁,更多可以看看StackOverFlow这个答案

要成对的使用

objc_sync_enter(object)
//Do something with object
objc_sync_exit(object)

Lock(锁)

先看看不加锁会出现什么情况,可以先看看Objc上关于计数器的例子,那个可能更简单更直接一点。

举个例子
一个很简单的Swift的Model 类

class Person{
    var name:String
    var age:UInt32
    init(name:String,age:UInt32){
        self.name = name
        self.age = age
    }
    func update(name:String,delay:UInt32,age:UInt32){
        self.name = name
        self.age = age
    }
}

这里,要明白那么,这个update在并行更新Self的时候,就会有问题了。画一张图来详细解释下
当我们在线程一上更新person为name:jack,age25,线程二上更新为另一个

于是,我们得到了一个混合的值,这个值是name lucy,age 25,这是一个完全没有任何意义的值。而且, 这种错误,很难调试
用代码来模拟这种情况

class ViewController: UIViewController {
    var person = Person(name: "Leo",age: 23)
    override func viewDidLoad() {
        super.viewDidLoad()
        let queue1 = dispatch_queue_create("com.test.queue1",DISPATCH_QUEUE_SERIAL)
        let queue2 = dispatch_queue_create("com.test.queue1",DISPATCH_QUEUE_SERIAL)
        dispatch_async(queue1) { () -> Void in
            self.person.update("jack",delay: 2,age: 25)
        }
        dispatch_async(queue2) { () -> Void in
            self.person.update("lucy",delay: 1,age: 24)
        }
        self.performSelector("logPerson",withObject: nil,afterDelay: 4)
        // Do any additional setup after loading the view,typically from a nib.
    }
    func logPerson(){
        NSLog("%@ %d",person.name,person.age)
    }
}

可以看输出

lucy 25

使用互斥锁-NSLock

先看一下这个类的文档

An NSLock object is used to coordinate the operation of multiple threads of execution within the same application. An NSLock object can be used to mediate access to an application’s global data or to protect a critical section of code,allowing it to run atomically.

这个类继承自NSObject,实现了NSLocking协议
其中NSLocking协议,定义了两个方法,lock和unlock。用来加锁,解锁。

使用NSLock的时候,要注意unlock的调用要和lock在同一线程上

当我们调用互斥锁进行加锁以后

class ViewController: UIViewController {
    let lock = NSLock()
    var person = Person(name: "Leo",age: 23)
    override func viewDidLoad() {
        super.viewDidLoad()
        let queue1 = dispatch_queue_create("com.test.queue1",DISPATCH_QUEUE_SERIAL)
        let queue2 = dispatch_queue_create("com.test.queue1",DISPATCH_QUEUE_SERIAL)
        dispatch_async(queue1) { () -> Void in
            self.lock.lock()
            self.person.update("queue1",age: 1)
            self.lock.unlock()
        }
        dispatch_async(queue2) { () -> Void in
            self.lock.lock()
            self.person.update("queue2",age: 2)
            self.lock.unlock()
        }
        self.performSelector("logPerson",afterDelay: 4)
        // Do any additional setup after loading the view,typically from a nib.
    }
    func logPerson(){
        NSLog("%@ %d",person.name,person.age)
    }

}

输出

Lucy 24

死锁

把上述代码修改为

dispatch_async(queue1) { () -> Void in
            self.lock.lock()
            self.lock.lock()
            self.person.update("Jack",age: 25)
            self.lock.unlock()
            self.lock.unlock()
        }

然后,你就会发现死锁了

2015-11-26 12:28:23.245 LeoThreadSafe[1365:131272] * -[NSLock lock]: deadlock ( ‘(null)’)

最后,住线程Log输出

2015-11-26 12:28:27.266 LeoThreadSafe[1365:131140] Leo 23

死锁的原因
线程1等待自己的结束,也就造成了一个死循环:自己不结束就一直等待,自己等待就没办法结束。同样,线程2因为要等待线程1的lock解锁才能开始,线程2直接就不能执行了,所以输出Leo 23

当然,死锁也会发生在线程之间

线程之前相互等待对方解锁,才能继续

递归锁

iOS中,除了NSLock之外,还提供了递归锁,递归锁解决了NSLock在同一个线程上不能多次加锁的问题。
相关类 - NSRecursiveLock

NSRecursiveLock defines a lock that may be acquired multiple times by the same thread without causing a deadlock,a situation where a thread is permanently blocked waiting for itself to relinquish a lock. While the locking thread has one or more locks,all other threads are prevented from accessing the code protected by the lock.
NSRecursiveLock定义了一种锁,这种锁能够在同一个线程上多次加锁,而不会引起死锁(一个线程永远的等待自己解锁)。当被锁住的线程有一个或者多个锁的时候,其他线程就不能访问被保护的代码。

把上文的例子换成递归锁,就能够正常输出了

let lock = NSRecursiveLock()

条件锁

Cocoa还提供了另外一种跟高级的锁-NSConditionLock,顾名思义,按照某种条件加锁。

class ViewController: UIViewController {

    let lock = NSConditionLock(condition: 10)
    var person = Person(name: "Leo",DISPATCH_QUEUE_SERIAL)
        dispatch_async(queue1) { () -> Void in
            self.lock.lockWhenCondition(10)
            self.person.update("Jack",age: 25)
            self.lock.unlockWithCondition(10)
        }
        dispatch_async(queue2) { () -> Void in
            self.lock.lockWhenCondition(10)
            self.person.update("Lucy",age: 24)
            self.lock.unlockWithCondition(10)
        }
        self.performSelector("logPerson",person.age)
    }

}

可重入

Wiki的定义

简单来说,就是程序的执行过程中可能会发生中断,一个函数(代码)在中间中断后,再继续执行(
重入),可以正常再一次从头执行这个函数,而不要等待上一次执行完毕。

比如这个C函数

int function()
{
    mutex_lock();
    // ...
    function body
    // ...
    mutex_unlock();
}

如果在body处中断,则改线程一直加锁,不能重入。

关于Objective C

参考这篇文章

Atomic

一个非Atomic的属性在非ARC的时候像这样

- (void)setUserName:(NSString *)userName { if (userName != _userName) { [userName retain]; [_userName release]; _userName = userName; } }

可以看到,如果在多线程同时set的情况下,可能会造成release两次。程序崩溃。
Property的Runtime对应的C代码为

static inline void reallySetProperty(id self,SEL _cmd,id newValue,ptrdiff_t offset,bool atomic,bool copy,bool mutableCopy) 
{
    id oldValue;
    id *slot = (id*) ((char*)self + offset);

    if (copy) {
        newValue = [newValue copyWithZone:NULL];
    } else if (mutableCopy) {
        newValue = [newValue mutableCopyWithZone:NULL];
    } else {
        if (*slot == newValue) return;
        newValue = objc_retain(newValue);
    }

    if (!atomic) {
        oldValue = *slot;
        *slot = newValue;
    } else {
        spin_lock_t *slotlock = &PropertyLocks[GOODHASH(slot)];
        _spin_lock(slotlock);
        oldValue = *slot;
        *slot = newValue;        
        _spin_unlock(slotlock);
    }

    objc_release(oldValue);
}

可以看到,如果是nonatomic的,

synchronized

可以看看这个StackOverflow问题
这个关键词会对访问的变量加互斥锁

- (NSString *)myString {
  @synchronized(self) {
    return [[myString retain] autorelease];
  }
}

可以类似转变为(实际转变肯能要更复杂,可以这么理解)

- (NSString *)myString {
  NSString *retval = nil;
  pthread_mutex_t *self_mutex = LOOK_UP_MUTEX(self);
  pthread_mutex_lock(self_mutex);
  retval = [[myString retain] autorelease];
  pthread_mutex_unlock(self_mutex);
  return retval;
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


软件简介:蓝湖辅助工具,减少移动端开发中控件属性的复制和粘贴.待开发的功能:1.支持自动生成约束2.开发设置页面3.做一个浏览器插件,支持不需要下载整个工程,可即时操作当前蓝湖浏览页面4.支持Flutter语言模板生成5.支持更多平台,如Sketch等6.支持用户自定义语言模板
现实生活中,我们听到的声音都是时间连续的,我们称为这种信号叫模拟信号。模拟信号需要进行数字化以后才能在计算机中使用。目前我们在计算机上进行音频播放都需要依赖于音频文件。那么音频文件如何生成的呢?音频文件的生成过程是将声音信息采样、量化和编码产生的数字信号的过程,我们人耳所能听到的声音频率范围为(20Hz~20KHz),因此音频文件格式的最大带宽是20KHZ。根据奈奎斯特的理论,音频文件的采样率一般在40~50KHZ之间。奈奎斯特采样定律,又称香农采样定律。...............
前言最近在B站上看到一个漂亮的仙女姐姐跳舞视频,循环看了亿遍又亿遍,久久不能离开!看着小仙紫姐姐的蹦迪视频,除了一键三连还能做什么?突发奇想,能不能把舞蹈视频转成代码舞呢?说干就干,今天就手把手教大家如何把跳舞视频转成代码舞,跟着仙女姐姐一起蹦起来~视频来源:【紫颜】见过仙女蹦迪吗 【千盏】一、核心功能设计总体来说,我们需要分为以下几步完成:从B站上把小姐姐的视频下载下来对视频进行截取GIF,把截取的GIF通过ASCII Animator进行ASCII字符转换把转换的字符gif根据每
【Android App】实战项目之仿抖音的短视频分享App(附源码和演示视频 超详细必看)
前言这一篇博客应该是我花时间最多的一次了,从2022年1月底至2022年4月底。我已经将这篇博客的内容写为论文,上传至arxiv:https://arxiv.org/pdf/2204.10160.pdf欢迎大家指出我论文中的问题,特别是语法与用词问题在github上,我也上传了完整的项目:https://github.com/Whiffe/Custom-ava-dataset_Custom-Spatio-Temporally-Action-Video-Dataset关于自定义ava数据集,也是后台
因为我既对接过session、cookie,也对接过JWT,今年因为工作需要也对接了gtoken的2个版本,对这方面的理解还算深入。尤其是看到官方文档评论区又小伙伴表示看不懂,所以做了这期视频内容出来:视频在这里:本期内容对应B站的开源视频因为涉及的知识点比较多,视频内容比较长。如果你觉得看视频浪费时间,可以直接阅读源码:goframe v2版本集成gtokengoframe v1版本集成gtokengoframe v2版本集成jwtgoframe v2版本session登录官方调用示例文档jwt和sess
【Android App】实战项目之仿微信的私信和群聊App(附源码和演示视频 超详细必看)
用Android Studio的VideoView组件实现简单的本地视频播放器。本文将讲解如何使用Android视频播放器VideoView组件来播放本地视频和网络视频,实现起来还是比较简单的。VideoView组件的作用与ImageView类似,只是ImageView用于显示图片,VideoView用于播放视频。...
采用MATLAB对正弦信号,语音信号进行生成、采样和内插恢复,利用MATLAB工具箱对混杂噪声的音频信号进行滤波
随着移动互联网、云端存储等技术的快速发展,包含丰富信息的音频数据呈现几何级速率增长。这些海量数据在为人工分析带来困难的同时,也为音频认知、创新学习研究提供了数据基础。在本节中,我们通过构建生成模型来生成音频序列文件,从而进一步加深对序列数据处理问题的了解。
基于yolov5+deepsort+slowfast算法的视频实时行为检测。1. yolov5实现目标检测,确定目标坐标 2. deepsort实现目标跟踪,持续标注目标坐标 3. slowfast实现动作识别,并给出置信率 4. 用框持续框住目标,并将动作类别以及置信度显示在框上
数字电子钟设计本文主要完成数字电子钟的以下功能1、计时功能(24小时)2、秒表功能(一个按键实现开始暂停,另一个按键实现清零功能)3、闹钟功能(设置闹钟以及到时响10秒)4、校时功能5、其他功能(清零、加速、星期、八位数码管显示等)前排提示:前面几篇文章介绍过的内容就不详细介绍了,可以看我专栏的前几篇文章。PS.工程文件放在最后面总体设计本次设计主要是在前一篇文章 数字电子钟基本功能的实现 的基础上改编而成的,主要结构不变,分频器将50MHz分为较低的频率备用;dig_select
1.进入官网下载OBS stdioOpen Broadcaster Software | OBS (obsproject.com)2.下载一个插件,拓展OBS的虚拟摄像头功能链接:OBS 虚拟摄像头插件.zip_免费高速下载|百度网盘-分享无限制 (baidu.com)提取码:6656--来自百度网盘超级会员V1的分享**注意**该插件必须下载但OBS的根目录(应该是自动匹配了的)3.打开OBS,选中虚拟摄像头选择启用在底部添加一段视频录制选择下面,进行录制.
Meta公司在9月29日首次推出一款人工智能系统模型:Make-A-Video,可以从给定的文字提示生成短视频。基于**文本到图像生成技术的最新进展**,该技术旨在实现文本到视频的生成,可以仅用几个单词或几行文本生成异想天开、独一无二的视频,将无限的想象力带入生活
音频信号叠加噪声及滤波一、前言二、信号分析及加噪三、滤波去噪四、总结一、前言之前一直对硬件上的内容比较关注,但是可能是因为硬件方面的东西可能真的是比较杂,而且需要渗透的东西太多了,所以学习进展比较缓慢。因为也很少有单纯的硬件学习研究,总是会伴随着各种理论需要硬件做支撑,所以还是想要慢慢接触理论学习。但是之前总找不到切入点,不知道从哪里开始,就一直拖着。最近稍微接触了一点信号处理,就用这个当作切入点,开始接触理论学习。二、信号分析及加噪信号处理选用了matlab做工具,选了一个最简单的语音信号处理方
腾讯云 TRTC 实时音视频服务体验,从认识 TRTC 到 TRTC 的开发实践,Demo 演示& IM 服务搭建。
音乐音频分类技术能够基于音乐内容为音乐添加类别标签,在音乐资源的高效组织、检索和推荐等相关方面的研究和应用具有重要意义。传统的音乐分类方法大量使用了人工设计的声学特征,特征的设计需要音乐领域的知识,不同分类任务的特征往往并不通用。深度学习的出现给更好地解决音乐分类问题提供了新的思路,本文对基于深度学习的音乐音频分类方法进行了研究。首先将音乐的音频信号转换成声谱作为统一表示,避免了手工选取特征存在的问题,然后基于一维卷积构建了一种音乐分类模型。
C++知识精讲16 | 井字棋游戏(配资源+视频)【赋源码,双人对战】
本文主要讲解如何在Java中,使用FFmpeg进行视频的帧读取,并最终合并成Gif动态图。
在本篇博文中,我们谈及了 Swift 中 some、any 关键字以及主关联类型(primary associated types)的前世今生,并由浅及深用简明的示例向大家讲解了它们之间的奥秘玄机。