关于 synchronized,这儿比你想知道的还要多
yuyutoo 2024-12-12 15:53 2 浏览 0 评论
因为原文一些内容写的不太准确,我按照我的理解做出了批注和补充。
如果你已经使用 Objective-C 编写过任何并发程序,那么想必是见过 @synchronized 这货了。@synchronized 结构所做的事情跟锁(lock)类似:它防止不同的线程同时执行同一段代码。但在某些情况下,相比于使用 NSLock 创建锁对象、加锁和解锁来说,@synchronized 用着更方便,可读性更高。
译者注:这与苹果官方文档对 @synchronized 的介绍有少许出入,但意思差不多。苹果官方文档更强调它“防止不同的线程同时获取相同的锁”,因为文档在集中介绍多线程编程各种锁的作用,所以更强调“相同的锁”而不是“同一段代码”。
如果你之前没用过 @synchronized,接下来有个使用它的例子。这篇文章实质上是谈谈有关我对 @synchronized 实现原理的一个简短研究。
用到 @synchronized 的例子
假设我们正在用 Objective-C 实现一个线程安全的队列,我们一开始可能会这么干:
@implementation?ThreadSafeQueue { ????NSMutableArray?*_elements; ????NSLock?*_lock; } -?(instancetype)init { ????self?=?[super?init]; ????if?(self)?{ ????????_elements?=?[NSMutableArray?array]; ????????_lock?=?[[NSLock?alloc]?init]; ????} ????return?self; } -?(void)push:(id)element { ????[_lock?lock]; ????[_elements?addObject:element]; ????[_lock?unlock]; } @end
上面的 ThreadSafeQueue 类有个 init 方法,它初始化了一个 _elements 数组和一个 NSLock 实例。这个类还有个 push: 方法,它先获取锁、然后向数组中插入元素、最终释放锁。可能会有许多线程同时调用 push: 方法,但是 [_elements addObject:element] 这行代码在任何时候将只会在一个线程上运行。步骤如下:
线程 A 调用 push: 方法
线程 B 调用 push: 方法
线程 B 调用 [_lock lock] - 因为当前没有其他线程持有锁,线程 B 获得了锁
线程 A 调用 [_lock lock],但是锁已经被线程 B 占了所以方法调用并没有返回-这会暂停线程 A 的执行
线程 B 向 _elements 添加元素后调用 [_lock unlock]。当这些发生时,线程 A 的 [_lock lock] 方法返回,并继续将自己的元素插入 _elements。
我们可以用 @synchronized 结构更简要地实现这些:
@implementation?ThreadSafeQueue { ????NSMutableArray?*_elements; } -?(instancetype)init { ????self?=?[super?init]; ????if?(self)?{ ????????_elements?=?[NSMutableArray?array]; ????} ????return?self; } -?(void)increment { ????@synchronized?(self)?{ ????????[_elements?addObject:element]; ????} } @end
在前面的例子中,”synchronized block” 与 [_lock lock] 和 [_lock unlock] 效果相同。你可以把它当成是锁住 self,仿佛 self 就是个 NSLock。锁在左括号 { 后面的任何代码运行之前被获取到,在右括号 } 后面的任何代码运行之前被释放掉。这爽就爽在妈妈再也不用担心我忘记调用 unlock 了!
你可以给任何 Objective-C 对象上加个 @synchronized。那么我们也可以在上面的例子中用 @synchronized(_elements) 来替代 @synchronized(self),效果是相同的。
回到研究上来
我对 @synchronized 的实现十分好奇并搜了一些它的细节。我找到了一些答案,但这些解释都没有达到我想要的深度。锁是如何与你传入 @synchronized 的对象关联上的?@synchronized会保持(retain,增加引用计数)被锁住的对象么?假如你传入 @synchronized 的对象在 @synchronized 的 block 里面被释放或者被赋值为 nil 将会怎么样?这些全都是我想回答的问题。而我这次的收获,会要你好看。
@synchronized 的文档告诉我们 @synchronized block 在被保护的代码上暗中添加了一个异常处理。为的是同步某对象时如若抛出异常,锁会被释放掉。
SO 上的这篇帖子说 @synchronized block 会变成 objc_sync_enter 和 objc_sync_exit 的成对儿调用。我们不知道这些函数是干啥的,但基于这些事实我们可以认为编译器将这样的代码:
@synchronized(obj)?{ ????//?do?work }
转化成这样的东东:
@try?{ ????objc_sync_enter(obj); ????//?do?work }?@finally?{ ????objc_sync_exit(obj);???? }
objc_sync_enter 和 objc_sync_exit 是什么鬼?它们是如何实现的?在 Xcode 中按住 Command 键单击它们,然后进到了,里面有我们感兴趣的这两个函数:
/**? ?*?Begin?synchronizing?on?'obj'.?? ?*?Allocates?recursive?pthread_mutex?associated?with?'obj'?if?needed. ?*? ?*?@param?obj?The?object?to?begin?synchronizing?on. ?*? ?*?@return?OBJC_SYNC_SUCCESS?once?lock?is?acquired.?? ?*/ OBJC_EXPORT??int?objc_sync_enter(id?obj) ????__OSX_AVAILABLE_STARTING(__MAC_10_3,?__IPHONE_2_0); /**? ?*?End?synchronizing?on?'obj'.? ?*? ?*?@param?obj?The?objet?to?end?synchronizing?on. ?*? ?*?@return?OBJC_SYNC_SUCCESS?or?OBJC_SYNC_NOT_OWNING_THREAD_ERROR ?*/ OBJC_EXPORT??int?objc_sync_exit(id?obj) ????__OSX_AVAILABLE_STARTING(__MAC_10_3,?__IPHONE_2_0);
文件底部的一句话提醒着我们:苹果工程师也是人啊哈哈
//?The?wait/notify?functions?have?never?worked?correctly?and?no?longer?exist. OBJC_EXPORT??int?objc_sync_wait(id?obj,?long?long?milliSecondsMaxWait)? ????UNAVAILABLE_ATTRIBUTE; OBJC_EXPORT??int?objc_sync_notify(id?obj)? ????UNAVAILABLE_ATTRIBUTE; OBJC_EXPORT??int?objc_sync_notifyAll(id?obj)? ????UNAVAILABLE_ATTRIBUTE;
译者注: 此处原文摘抄的源码较旧,所以我替换上了最新的头文件源码。
不过,objc_sync_enter 的文档告诉我们一些新东西: @synchronized 结构在工作时为传入的对象分配了一个递归锁。分配工作何时发生,如何发生呢?它怎样处理 nil?幸运的是 Objective-C runtime 是开源的,所以我们可以马上阅读源码并找到答案!
注:递归锁在被同一线程重复获取时不会产生死锁。你可以在这找到一个它工作原理的精巧案例。有个叫做 NSRecursiveLock 的现成的类也是这样的,你可以试试。
你可以在这里找到 objc-sync 的全部源码,但我要带着你看源码,让你屌的飞起。我们先从文件顶部的数据结构开始看。在代码块的下方我将立刻做出解释,所以尝试理解代码时别花太长时间哦。
typedef?struct?SyncData?{ ????id?object; ????recursive_mutex_t?mutex; ????struct?SyncData*?nextData; ????int?threadCount; }?SyncData; typedef?struct?SyncList?{ ????SyncData?*data; ????spinlock_t?lock; }?SyncList; //?Use?multiple?parallel?lists?to?decrease?contention?among?unrelated?objects. #define?COUNT?16 #define?HASH(obj)?((((uintptr_t)(obj))?>>?5)?&?(COUNT?-?1)) #define?LOCK_FOR_OBJ(obj)?sDataLists[HASH(obj)].lock #define?LIST_FOR_OBJ(obj)?sDataLists[HASH(obj)].data static?SyncList?sDataLists[COUNT];
一开始,我们有一个 struct SyncData 的定义。这个结构体包含一个 object(嗯就是我们给 @synchronized 传入的那个对象)和一个有关联的 recursive_mutex_t,它就是那个跟 object 关联在一起的锁。每个 SyncData 也包含一个指向另一个 SyncData 对象的指针,叫做 nextData,所以你可以把每个 SyncData 结构体看做是链表中的一个元素。最后,每个 SyncData 包含一个 threadCount,这个 SyncData 对象中的锁会被一些线程使用或等待,threadCount 就是此时这些线程的数量。它很有用处,因为 SyncData 结构体会被缓存,threadCount==0 就暗示了这个 SyncData 实例可以被复用。
下面是 struct SyncList 的定义。正如我在上面提过,你可以把 SyncData 当做是链表中的节点。每个 SyncList 结构体都有个指向 SyncData 节点链表头部的指针,也有一个用于防止多个线程对此列表做并发修改的锁。
上面代码块的最后一行是 sDataLists 的声明 - 一个 SyncList 结构体数组,大小为16。通过定义的一个哈希算法将传入对象映射到数组上的一个下标。值得注意的是这个哈希算法设计的很巧妙,是将对象指针在内存的地址转化为无符号整型并右移五位,再跟 0xF 做按位与运算,这样结果不会超出数组大小。 LOCK_FOR_OBJ(obj) 和 LIST_FOR_OBJ(obj) 这俩宏就更好理解了,先是哈希出对象的数组下标,然后取出数组对应元素的 lock 或 data。一切都是这么顺理成章哈。
当你调用 objc_sync_enter(obj) 时,它用 obj 内存地址的哈希值查找合适的 SyncData,然后将其上锁。当你调用 objc_sync_exit(obj) 时,它查找合适的 SyncData 并将其解锁。
译者注:上面的源码和几段解释有些原文解释不清和疏漏的地方,我看了源码后按照自己的理解进行了补充和修正。
噢耶!现在我们知道了 @synchronized 如何将一个锁和你正在同步的对象关联起来,我希望聊聊当一个对象在 @synchronized block 当中被释放或设为 nil 时会发生什么。
如果你看了源码,你会注意到 objc_sync_enter 里面没有 retain 和 release。所以它要么没有保持传递给它的对象,要么或是在 ARC 下被编译。我们可以用下面的代码来做个测试:
NSDate?*test?=?[NSDate?date]; //?This?should?always?be?`1` NSLog(@"%@",?@([test?retainCount])); @synchronized?(test)?{ ????//?This?will?be?`2`?if?`@synchronized`?somehow ????//?retains?`test` ????NSLog(@"%@",?@([test?retainCount])); }
两次输出结果都是 1。那么 objc_sync_enter 貌似是没保持被传入的对象啊。这就有趣了。如果你正在同步的对象被释放了,然后有可能另一个新的对象在此处(被释放对象的内存地址)被分配内存。有可能某个其他的线程试着去同步那个新的对象(就是那个在被释放的旧对象的内存地址上刚刚新创建的对象)。在这种情况下,另一个线程将会阻塞,直到当前线程结束它的同步 block。这看起来并不是很糟。这听起来像是这种事情实现者早就知道并予以接受。我没有遇到过任何好的替代方案。
假如对象在 “synchronized block” 中被设成 nil 呢?我们回顾下我们“拿衣服(naive)”的实现吧:
NSString?*test?=?@"test"; @try?{ ????//?Allocates?a?lock?for?test?and?locks?it ????objc_sync_enter(test); ????test?=?nil; }?@finally?{ ????//?Passed?`nil`,?so?the?lock?allocated?in?`objc_sync_enter` ????//?above?is?never?unlocked?or?deallocated ????objc_sync_exit(test);??? }
objc_sync_enter 被调用时传入的是 test 而 objc_sync_exit 被调用时传入的是 nil。而传入 nil 的时候 objc_sync_exit 是个空操作,所以将不会有人释放锁。这真操蛋!
如果 Objective-C 容易受这种情况的影响,我们知道么?下面的代码调用 @synchronized 并在 @synchronized block 中将一个指针设为 nil。然后在后台线程对指向同一个对象的指针调用 @synchronized。如果在 @synchronized block 中设置一个对象为 nil 会让锁死锁,那么在第二个 @synchronized 中的代码将永远不会执行。我们将不会在控制台中看见任何东西打印出来。
NSNumber?*number?=?@(1); NSNumber?*thisPtrWillGoToNil?=?number; @synchronized?(thisPtrWillGoToNil)?{ ????/** ?????*?Here?we?set?the?thing?that?we're?synchronizing?on?to?`nil`.?If ?????*?implemented?naively,?the?object?would?be?passed?to?`objc_sync_enter` ?????*?and?`nil`?would?be?passed?to?`objc_sync_exit`,?causing?a?lock?to ?????*?never?be?released. ?????*/ ????thisPtrWillGoToNil?=?nil; } dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_BACKGROUND,?0),?^?{ ????NSCAssert(![NSThread?isMainThread],?@"Must?be?run?on?background?thread"); ????/** ?????*?If,?as?mentioned?in?the?comment?above,?the?synchronized?lock?is?never ?????*?released,?then?we?expect?to?wait?forever?below?as?we?try?to?acquire ?????*?the?lock?associated?with?`number`. ?????* ?????*?This?doesn't?happen,?so?we?conclude?that?`@synchronized`?must?deal ?????*?with?this?correctly. ?????*/ ????@synchronized?(number)?{ ????????NSLog(@"This?line?does?indeed?get?printed?to?stdout"); ????} });
当我们执行上面的代码时,那行代码确实打印到控制台了!所以 Objective-C 很好地处理了这种情形。我打赌是编译器做了类似下面的事情来解决这事儿的。
NSString?*test?=?@"test"; id?synchronizeTarget?=?(id)test; @try?{ ????objc_sync_enter(synchronizeTarget); ????test?=?nil; }?@finally?{ ????objc_sync_exit(synchronizeTarget);??? }
用这种方式实现的话,传递给 objc_sync_enter 和 objc_sync_exit 总是相同的对象。他们在传入 nil 时都是空操作。这带来了个棘手的 debug 场景:如果你向 @synchronized 传递 nil,那么你就不会得到任何锁而且你的代码将不会是线程安全的!如果你想知道为什么你正收到出乎意料的竞态(race),确保你没向你的 @synchronized 传入 nil。你可以在 objc_sync_nil 上设置一个符号断点来达到此目的。objc_sync_nil 是一个空方法,当 objc_sync_enter 函数被传入 nil 时会被调用,折让 debug 更容易些。
译者注:下面是 objc_sync_enter 的源码,主要逻辑很容易看懂,加深理解 objc_sync_nil:
int?objc_sync_enter(id?obj) { ????int?result?=?OBJC_SYNC_SUCCESS; ????if?(obj)?{ ????????SyncData*?data?=?id2data(obj,?ACQUIRE); ????????require_action_string(data?!=?NULL,?done,?result?=?OBJC_SYNC_NOT_INITIALIZED,?"id2data?failed"); ????????result?=?recursive_mutex_lock(&data->mutex); ????????require_noerr_string(result,?done,?"mutex_lock?failed"); ????}?else?{ ????????//?@synchronized(nil)?does?nothing ????????if?(DebugNilSync)?{ ????????????_objc_inform("NIL?SYNC?DEBUG:?@synchronized(nil);?set?a?breakpoint?on?objc_sync_nil?to?debug"); ????????} ????????objc_sync_nil; ????} done:? ????return?result; }
这回答了我眼下的问题。
你调用 sychronized 的每个对象,Objective-C runtime 都会为其分配一个递归锁并存储在哈希表中。
如果在 sychronized 内部对象被释放或被设为 nil 看起来都 OK。不过这没在文档中说明,所以我不会再生产代码中依赖这条。
注意不要向你的 sychronized block 传入 nil!这将会从代码中移走线程安全。你可以通过在 objc_sync_nil 上加断点来查看是否发生了这样的事情。
研究的下一步将是研究下 “synchronized block” 输出的汇编,看看它是否跟我上面的例子相似。我打赌 @synchronized block 的汇编输出不会跟任何我们设计的 Objective-C 代码相同,上面的代码充其量是 @synchronized 的工作模型。你能想到更好的模型么?我的模型在哪些情形下会有瑕疵么?告诉我吧!
相关推荐
- Mysql和Oracle实现序列自增(oracle创建序列的sql)
-
Mysql和Oracle实现序列自增/*ORACLE设置自增序列oracle本身不支持如mysql的AUTO_INCREMENT自增方式,我们可以用序列加触发器的形式实现,假如有一个表T_WORKM...
- 关于Oracle数据库12c 新特性总结(oracle数据库19c与12c)
-
概述今天主要简单介绍一下Oracle12c的一些新特性,仅供参考。参考:http://docs.oracle.com/database/121/NEWFT/chapter12102.htm#NEWFT...
- MySQL CREATE TABLE 简单设计模板交流
-
推荐用MySQL8.0(2018/4/19发布,开发者说同比5.7快2倍)或同类型以上版本....
- mysql学习9:创建数据库(mysql5.5创建数据库)
-
前言:我也是在学习过程中,不对的地方请谅解showdatabases;#查看数据库表createdatabasename...
- MySQL面试题-CREATE TABLE AS 与CREATE TABLE LIKE的区别
-
执行"CREATETABLE新表ASSELECT*FROM原表;"后,新表与原表的字段一致,但主键、索引不会复制到新表,会把原表的表记录复制到新表。...
- Nike Dunk High Volt 和 Bright Spruce 预计将于 12 月推出
-
在街上看到的PandaDunk的超载可能让一些球鞋迷们望而却步,但Dunk的浪潮仍然强劲,看不到尽头。我们看到的很多版本都是为女性和儿童制作的,这种新配色为后者引入了一种令人耳目一新的新选择,而...
- 美国多功能舰载雷达及美国海军舰载多功能雷达系统技术介绍
-
多功能雷达AN/SPY-1的特性和技术能力,该雷达已经在美国海军服役了30多年,其修改-AN/SPY-1A、AN/SPY-1B(V)、AN/SPY-1D、AN/SPY-1D(V),以及雷神...
- 汽车音响怎么玩,安装技术知识(汽车音响怎么玩,安装技术知识视频)
-
全面分析汽车音响使用或安装技术常识一:主机是大多数人最熟习的音响器材,有关主机的各种性能及规格,也是耳熟能详的事,以下是一些在使用或安装时,比较需要注意的事项:LOUDNESS:几年前的主机,此按...
- 【推荐】ProAc Response系列扬声器逐个看
-
有考牌(公认好声音)扬声器之称ProAcTablette小音箱,相信不少音响发烧友都曾经,或者现在依然持有,正当大家逐渐掌握Tablette的摆位设定与器材配搭之后,下一步就会考虑升级至表现更全...
- #本站首晒# 漂洋过海来看你 — BLACK&DECKER 百得 BDH2000L无绳吸尘器 开箱
-
作者:初吻给了烟sco混迹张大妈时日不短了,手没少剁。家里有了汪星人,吸尘器使用频率相当高,偶尔零星打扫用卧式的实在麻烦(汪星人:你这分明是找借口,我掉毛是满屋子都有,铲屎君都是用卧式满屋子吸的,你...
- 专题|一个品牌一件产品(英国篇)之Quested(罗杰之声)
-
Quested(罗杰之声)代表产品:Q212FS品牌介绍Quested(罗杰之声)是录音监听领域的传奇品牌,由英国录音师RogerQuested于1985年创立。在成立Quested之前,Roger...
- 常用半导体中英对照表(建议收藏)(半导体英文术语)
-
作为一个源自国外的技术,半导体产业涉及许多英文术语。加之从业者很多都有海外经历或习惯于用英文表达相关技术和工艺节点,这就导致许多英文术语翻译成中文后,仍有不少人照应不上或不知如何翻译。为此,我们整理了...
- Fyne Audio F502SP 2.5音路低音反射式落地音箱评测
-
FyneAudio的F500系列,有新成员了!不过,新成员不是新的款式,却是根据原有款式提出特别版。特别版产品在原有型号后标注了SP字样,意思是SpecialProduction。Fyne一共推出...
- 有哪些免费的内存数据库(In-Memory Database)
-
以下是一些常见的免费的内存数据库:1.Redis:Redis是一个开源的内存数据库,它支持多种数据结构,如字符串、哈希表、列表、集合和有序集合。Redis提供了快速的读写操作,并且支持持久化数据到磁...
- RazorSQL Mac版(SQL数据库查询工具)
-
RazorSQLMac特别版是一款看似简单实则功能非常出色的SQL数据库查询、编辑、浏览和管理工具。RazorSQLformac特别版可以帮你管理多个数据库,支持主流的30多种数据库,包括Ca...
你 发表评论:
欢迎- 一周热门
-
-
前端面试:iframe 的优缺点? iframe有那些缺点
-
带斜线的表头制作好了,如何填充内容?这几种方法你更喜欢哪个?
-
漫学笔记之PHP.ini常用的配置信息
-
其实模版网站在开发工作中很重要,推荐几个参考站给大家
-
推荐7个模板代码和其他游戏源码下载的网址
-
[干货] JAVA - JVM - 2 内存两分 [干货]+java+-+jvm+-+2+内存两分吗
-
正在学习使用python搭建自动化测试框架?这个系统包你可能会用到
-
织梦(Dedecms)建站教程 织梦建站详细步骤
-
【开源分享】2024PHP在线客服系统源码(搭建教程+终身使用)
-
2024PHP在线客服系统源码+完全开源 带详细搭建教程
-
- 最近发表
-
- Mysql和Oracle实现序列自增(oracle创建序列的sql)
- 关于Oracle数据库12c 新特性总结(oracle数据库19c与12c)
- MySQL CREATE TABLE 简单设计模板交流
- mysql学习9:创建数据库(mysql5.5创建数据库)
- MySQL面试题-CREATE TABLE AS 与CREATE TABLE LIKE的区别
- Nike Dunk High Volt 和 Bright Spruce 预计将于 12 月推出
- 美国多功能舰载雷达及美国海军舰载多功能雷达系统技术介绍
- 汽车音响怎么玩,安装技术知识(汽车音响怎么玩,安装技术知识视频)
- 【推荐】ProAc Response系列扬声器逐个看
- #本站首晒# 漂洋过海来看你 — BLACK&DECKER 百得 BDH2000L无绳吸尘器 开箱
- 标签列表
-
- mybatis plus (70)
- scheduledtask (71)
- css滚动条 (60)
- java学生成绩管理系统 (59)
- 结构体数组 (69)
- databasemetadata (64)
- javastatic (68)
- jsp实用教程 (53)
- fontawesome (57)
- widget开发 (57)
- vb net教程 (62)
- hibernate 教程 (63)
- case语句 (57)
- svn连接 (74)
- directoryindex (69)
- session timeout (58)
- textbox换行 (67)
- extension_dir (64)
- linearlayout (58)
- vba高级教程 (75)
- iframe用法 (58)
- sqlparameter (59)
- trim函数 (59)
- flex布局 (63)
- contextloaderlistener (56)