多线程(四) @synchronized

多线程出现最多的就是安全问题,解决多线程安全问题就是加锁。
锁的种类有很多,每种锁使用场景、性能上都有所不同,我们写一个测试demo,测试各种锁的耗时,demo下载地址

这里需要注意一下,运行起来耗时并不是固定的,设备型号不同,版本号不同,是否使用模拟器执行完代码打印的结果并不相同,甚至都使用模拟器,打印结果都不一定每次相同,这个耗时仅供参考。

iphoneX 14.6
iphone12 Simulator
iphone12 Simulator

@synchronized

我们平时用的最多的锁就是@synchronized,这个锁的原理是什么,我们先来分析它。

分析它底层实现用什么方法呢?首先我们可以用xcrun生成对应的C++文件,看底层实现,或者我们直接打断点进入汇编去一步一步跟流程看它执行了哪些操作。

int main(int argc, char * argv[]) {
    NSString * appDelegateClassName;
    @autoreleasepool {
        // Setup code that might create autoreleased objects goes here.
        appDelegateClassName = NSStringFromClass([AppDelegate class]);
        
        
        @synchronized (appDelegateClassName) {
            NSLog(@"123");
        }
    }
    return UIApplicationMain(argc, argv, nil, appDelegateClassName);
}

我们把main.m文件生成C++文件,可以省去很多干扰,到main.m文件目录执行xcrun -sdk iphoneos clang -arch arm64 -rewrite-objc main.m -o main.cpp生成对应C++文件。

找到对应实现,首先我们先自己整理下格式,生成的格式不太方便我们研究,

{
    id _rethrow = 0;
    id _sync_obj = (id)appDelegateClassName;
    objc_sync_enter(_sync_obj);
    try {
        struct _SYNC_EXIT {
            _SYNC_EXIT(id arg) : sync_exit(arg) {}
            ~_SYNC_EXIT() {objc_sync_exit(sync_exit);}
            id sync_exit;
        }
        _sync_exit(_sync_obj);
        
        NSLog((NSString *)&__NSConstantStringImpl__var_folders_zc_4wbtwwn978v9__lzhp1kr15h0000gn_T_main_7e7e5b_mi_0);
    } catch (id e) {_rethrow = e;}
    {
        struct _FIN {
            _FIN(id reth) : rethrow(reth) {}
            ~_FIN() { if (rethrow) objc_exception_throw(rethrow); }
            id rethrow;
        }
        _fin_force_rethow(_rethrow);
    }
}

我们分析加锁流程,肯定是加锁成功,会执行try里面代码,catch里面不会执行,所以并不需要关心。try里面的结构体声明我们可以放在外面,先调用构造函数_sync_exit(_sync_obj);相当于结构体sync_exit赋值_sync_obj,当结构体释放时,调用析构函数时,执行objc_sync_exit(sync_exit),等价于objc_sync_exit(_sync_obj),所以我们可以简化成以下代码:

id _rethrow = 0;
id _sync_obj = (id)appDelegateClassName;
objc_sync_enter(_sync_obj);
objc_sync_exit(_sync_obj);

接下来打个断点,进入汇编看下执行流程:

@synchronized汇编流程

我们可以看到,汇编流程和我们上面分析流程差不多,要研究底层实现,就得去源码中查看相关代码。

int objc_sync_enter(id obj)
{
    int result = OBJC_SYNC_SUCCESS;

    if (obj) {
        SyncData* data = id2data(obj, ACQUIRE);
        ASSERT(data);
        data->mutex.lock();
    } 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();
    }

    return result;
}

这里有个细节,obj如果是空的话,注释写的很明白does nothing也就是什么都不做不会加锁直接执行代码块里面的内容,所以我们使用的时候,obj不能为空,否则没有加锁效果。

再看一下objc_sync_exit的实现对比着看。

int objc_sync_exit(id obj)
{
    int result = OBJC_SYNC_SUCCESS;
    
    if (obj) {
        SyncData* data = id2data(obj, RELEASE); 
        if (!data) {
            result = OBJC_SYNC_NOT_OWNING_THREAD_ERROR;
        } else {
            bool okay = data->mutex.tryUnlock();
            if (!okay) {
                result = OBJC_SYNC_NOT_OWNING_THREAD_ERROR;
            }
        }
    } else {
        // @synchronized(nil) does nothing
    }
    

    return result;
}

我们在C++代码中看返回值也没用使用的地方,这两个方法返回值也只是个标记加锁状态,没太多作用,所以重点代码就是:SyncData* data = id2data(obj, ACQUIRE);SyncData* data = id2data(obj, RELEASE);

首先我们先看下这个值的类型的定义:

typedef struct alignas(CacheLineSize) SyncData {
    struct SyncData* nextData;
    DisguisedPtr<objc_object> object;
    int32_t threadCount;  // number of THREADS using this block
    recursive_mutex_t mutex;
} SyncData;

第一个参数也是SyncData,并且命名是next也就是这个结构是个单向链表。
DisguisedPtr<objc_object>是对数据进行封装。
recursive_mutex_t是一个递归锁,递归锁不能多线程使用,但是有了threadCount之后,就可以支持多线程使用了。

再看下第二个参数

enum usage { ACQUIRE, RELEASE, CHECK };

一个枚举值,标记是获取、释放还是检查。
然后我们看下id2data方法实现,这个应该是最核心的代码了。

先分析下前三行代码:

spinlock_t *lockp = &LOCK_FOR_OBJ(object);
SyncData **listp = &LIST_FOR_OBJ(object);
SyncData* result = NULL;

listp为什么是个二级指针,为后面链表处理头插法做准备,一级指针无法满足需求。
找到实现:

#define LOCK_FOR_OBJ(obj) sDataLists[obj].lock
#define LIST_FOR_OBJ(obj) sDataLists[obj].data
static StripedMap<SyncList> sDataLists;

可以看到,sDataLists是个哈希列表,并且是个全局静态变量,这点很重要。
StripedMap实现里面看还有个细节:

#if TARGET_OS_IPHONE && !TARGET_OS_SIMULATOR
    enum { StripeCount = 8 };
#else
    enum { StripeCount = 64 };
#endif

也就是真机情况下,这个哈希列表容量是8,其他情况容量是64。

在可调式源码工程中,这个方法打断点,看下sDataLists的数据:

sDataLists

可以看到一共有64个数据。

下面我们开始分析方法主要实现,分析之前,需要对这些方法有个全局把控,大概知道这里面在干什么,大代码块收起,然后发现主要就几块内容:

id2data

整体看完我们就一块一块的分析。上面5块我们把他们叫成代码块一、代码块二、码块三、代码块四、码块五。

SyncData *data = (SyncData *)tls_get_direct(SYNC_DATA_DIRECT_KEY);

看这行代码前,首先要了解一个概念TLS:
线程局部存储(Thread Local Storage,TLS):是操作系统为线程单独提供的私有空间,通常只有有限的容量。Linux系统下通常通过pthread库中的pthread_key_create()pthread_getspecific()pthread_setspecific()pthread_key_delete()进行操作。

再看两个函数:
OSAtomicDecrement32Barrier(),原子性减1并存储。
OSAtomicIncrement32Barrier(),原子性加1并存储。

代码块一:
拿到data后先判断data是否有值,没有值的话什么都不做,有值的话再判断data-objectobject是否相同,不相同也什么都不做,相同的话,继续下面流程。
这里还把fastCacheOccupied设置为YES,下面使用,再存储的时候直接存到缓存里面不存tls了。为什么有这个操作,因为map容量固定,当hash算法算出下标相同时,会存在相同链表中,从tls取出只是固定的那个,其他对象对应的SyncData就只能放在别的地方也就是缓存里面。

  1. 先获取了锁的次数lockCount,记录了加锁几次。
  2. threadCountlockCount容错处理
  3. 根据策略,ACQUIRElockCount加1并存储。RELEASElockCount减1并存储,如果减到0,还要把threadCount也减1,并且从tls删除
  4. return result;

代码块二:
SyncCache *cache = fetch_cache(NO);,先把锁的线程缓存数据都拿出来,然后遍历,直到匹配到object相等时,跟上面操作差不多,对lockCount进行处理。lockCount减到0时候,从cache列表删除这个数据

image

下一块代码我们看见这里面有个加锁解锁的过程,这个并不是@synchronized的锁,而是锁中间内存开辟创建的代码,防止多线程抢占资源问题,这个需要注意一下。

代码块五:
我们先看done这块代码,因为上面会跳过来。

  1. 先判断result有值才会走下面逻辑。
  2. 如果是RELEASE直接返回nil
  3. 如果不是ACQUIRE,会报错处理
  4. 如果result->object != object,会报错处理
  5. 如果是没从tls取的,直接把tls设置下
  6. 否则就是缓存,如果cache是空的,再去取一次缓存,这是参数是YES也就是去创建缓存。然后把result存到缓存里面。

代码块三:
这快分析完了,回到上面

  1. 遍历listp链表,p不为空时,才会走里面代码,也就是这块并不是第一次会进来,而是后面才会来
  2. 如果p->object == objectthreadCount加1跳到done
  3. 如果firstUnused没被赋值过并且p->threadCount == 0firstUnused = p
  4. 如果RELEASE或者CHECK,直接跳到done
  5. 如果firstUnused有值,则赋值给result,并且跳到done
    总结下这小块逻辑,就是其他线程同一个对象加锁,过来会threadCount加1,其他线程不同对象,过来会找到链表最后一个位置,新建个对象,赋值存储

代码块四:
先开辟内存空间,result设置值,然后利用头插法,插入到listp链表的第一个位置。

总结:

  1. @synchronized参数一般用self因为保证参数生命周期大于这段代码执行生命周期,否则会有问题
  2. @synchronized参数一般用self可以减少链表数据的创建,节约性能
  3. @synchronized真机模拟器性能不同因为StripeCount值不同
  4. @synchronized支持递归可重入表现在lockCount++
  5. @synchronized支持多线程表现在threadCount++
  6. @synchronized参数不要为空,否则没有加锁作用
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 206,723评论 6 481
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 88,485评论 2 382
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 152,998评论 0 344
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 55,323评论 1 279
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 64,355评论 5 374
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,079评论 1 285
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,389评论 3 400
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,019评论 0 259
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,519评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,971评论 2 325
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,100评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,738评论 4 324
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,293评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,289评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,517评论 1 262
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,547评论 2 354
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,834评论 2 345

推荐阅读更多精彩内容