多線程

iOS常見的多線程方案

image.png

GCD源碼:https://github.com/apple/swift-corelibs-libdispatch

image.png

死鎖

- (void)viewDidLoad {
    [super viewDidLoad];
    
    NSLog(@"1");
    
    dispatch_queue_t queue = dispatch_get_main_queue();
    dispatch_sync(queue, ^{
        NSLog(@"2");
    });
    
    NSLog(@"3");
}

當前隊列需要等待viewDidLoad執(zhí)行完,才能執(zhí)行block里面的內容,而viewDidLoad又需要等待block執(zhí)行完.雙方都在等待對方完成,而造成的死鎖.

另一個死鎖

- (void)interView02
{
    NSLog(@"執(zhí)行任務1");
    
    dispatch_queue_t queue = dispatch_queue_create("myqueue", DISPATCH_QUEUE_SERIAL);
    
    dispatch_async(queue, ^{
        
        NSLog(@"執(zhí)行任務2");
        
        dispatch_sync(queue, ^{
            
            NSLog(@"執(zhí)行任務3");
            
        });
        
        NSLog(@"執(zhí)行任務4");
        
    });
    
    NSLog(@"執(zhí)行任務5");
}

網(wǎng)上一道面試題

- (void)test
{
    NSLog(@"3");
}

- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event
{
    dispatch_queue_t queque = dispatch_get_global_queue(0, 0);
    
    dispatch_async(queque, ^{
        
        NSLog(@"1");
        [self performSelector:@selector(test) withObject:nil
                   afterDelay:0];
        NSLog(@"2");
        
        [[NSRunLoop currentRunLoop]addPort:[NSPort new] forMode:NSDefaultRunLoopMode];
        [[NSRunLoop currentRunLoop]runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];
        
    });
    
}

[self performSelector:@selector(test) withObject:nil afterDelay:0];的本質是往runloop中添加定時器,子線程默認沒有開啟runloop.

GNUStep

是GNU計劃的項目之一,它將cocoa的oc庫開源實現(xiàn)了一遍,非常接近蘋果的源碼.
源碼地址:http://www.gnustep.org/resources/downloads.php 這里可以看到runloop的相關實現(xiàn)

多線程的隱患

當多個線程訪問同一塊資源時抛猫,很容易引發(fā)數(shù)據(jù)錯亂和數(shù)據(jù)安全問題
eg.存錢取錢問題.


@interface ViewController ()
@property (nonatomic,assign) int moeny;
@end

@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    
    self.moeny = 100;
    // Do any additional setup after loading the view.
    dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
    
    dispatch_async(queue, ^{
        for (int i = 0; i < 10; i++) {
            [self saveMoeny];
        }
    });
    
    dispatch_async(queue, ^{
        for (int i = 0; i < 10; i++) {
            [self drawMoney];
        }
    });
}

//取錢
- (void)drawMoney
{
    int oldMoeny = self.moeny;
    sleep(0.2);
    oldMoeny = oldMoeny - 20;
    self.moeny = oldMoeny;
    NSLog(@"取20, 還剩%d--%@",oldMoeny,[NSThread currentThread]);
}

//存錢
- (void)saveMoeny
{
    int newMoney = self.moeny;
    sleep(.2);
    newMoney = newMoney + 50;
    self.moeny = newMoney;
    NSLog(@"存50, 還剩%d--%@",newMoney,[NSThread currentThread]);
}

線程同步技術

  • OSSpinLock
  • os_unfair_lock
  • pthread_mutex
  • dispatch_semaphore
  • dispatch_queue(DISPATCH_QUEUE_SERIAL)
  • NSLock
  • NSRecursiveLock
  • NSCondition
  • NSConditionLock
  • @synchronized

OSSpinLock

  • OSSpinLock叫做”自旋鎖”浩蓉,等待鎖的線程會處于忙等(busy-wait)狀態(tài)峦失,一直占用著CPU資源
  • 目前已經(jīng)不再安全置侍,可能會出現(xiàn)優(yōu)先級反轉問題
  • 如果等待鎖的線程優(yōu)先級較高厉颤,它會一直占用著CPU資源转唉,優(yōu)先級低的線程就無法釋放鎖
  • #import <libkern/OSAtomic.h>

//取錢
- (void)drawMoney
{
    OSSpinLockLock(&_lock);
    
    int oldMoeny = self.moeny;
    sleep(0.2);
    oldMoeny = oldMoeny - 20;
    self.moeny = oldMoeny;
    NSLog(@"取20, 還剩%d--%@",oldMoeny,[NSThread currentThread]);
    
    OSSpinLockUnlock(&_lock);
}

//存錢
- (void)saveMoeny
{
    OSSpinLockLock(&_lock);
    int newMoney = self.moeny;
    
    sleep(.2);
    newMoney = newMoney + 50;
    self.moeny = newMoney;
    NSLog(@"存50, 還剩%d--%@",newMoney,[NSThread currentThread]);
    OSSpinLockUnlock(&_lock);
}

新建基類lockDemo,以后每個種類的lock繼承于它便于演示.

@interface lockDemo : NSObject

- (void)drawAndSaveMoneyTest;
- (void)ticketTest;

- (void)drawMoney;
- (void)saveMoeny;
- (void)saleTicket;

@end

@interface lockDemo ()

@property (nonatomic,assign) int moeny;
@property (nonatomic,assign) int ticketsCount;


@end

@implementation lockDemo

- (void)drawAndSaveMoneyTest
{
    self.moeny = 100;
    dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
    
    dispatch_async(queue, ^{
        for (int i = 0; i < 10; i++) {
            [self saveMoeny];
        }
    });
    
    dispatch_async(queue, ^{
        for (int i = 0; i < 10; i++) {
            [self drawMoney];
        }
    });
}

//取錢
- (void)drawMoney
{
    
    
    int oldMoeny = self.moeny;
    sleep(0.2);
    oldMoeny = oldMoeny - 20;
    self.moeny = oldMoeny;
    NSLog(@"取20, 還剩%d--%@",oldMoeny,[NSThread currentThread]);
    
    
}

//存錢
- (void)saveMoeny
{
    
    int newMoney = self.moeny;
    sleep(.2);
    newMoney = newMoney + 50;
    self.moeny = newMoney;
    NSLog(@"存50, 還剩%d--%@",newMoney,[NSThread currentThread]);
    
}

- (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, ^{
        for (int i = 0; i < 5; i++) {
            [self saleTicket];
        }
    });
    
    dispatch_async(queue, ^{
        for (int i = 0; i < 5; i++) {
            [self saleTicket];
        }
    });
    
    dispatch_async(queue, ^{
        for (int i = 0; i < 5; i++) {
            [self saleTicket];
        }
    });
}
@end

os_unfair_lock

  • os_unfair_lock用于取代不安全的OSSpinLock 孽惰,從iOS10開始才支持
  • 從底層調用看耕肩,等待os_unfair_lock鎖的線程會處于休眠狀態(tài),并非忙等
  • 需要導入頭文件#import <os/lock.h>
@interface os_unfair_locDemo()
@property (nonatomic,assign) os_unfair_lock  moneyLock;
@property (nonatomic,assign) os_unfair_lock  ticketLock;

@end


@implementation os_unfair_locDemo

- (instancetype)init
{
    self = [super init];
    if (self) {
        self.moneyLock = OS_UNFAIR_LOCK_INIT;
        self.ticketLock = OS_UNFAIR_LOCK_INIT;
    }
    return self;
}

- (void)saleTicket
{
    os_unfair_lock_lock(&_ticketLock);
    [super saleTicket];
    os_unfair_lock_unlock(&_ticketLock);
}

- (void)saveMoeny
{
    os_unfair_lock_lock(&_moneyLock);
    [super saveMoeny];
    os_unfair_lock_unlock(&_moneyLock);
}

- (void)drawMoney
{
    os_unfair_lock_lock(&_moneyLock);
    [super drawMoney];
    os_unfair_lock_unlock(&_moneyLock);
}
@end

pthread_mutex

  • mutex叫做”互斥鎖”欲逃,等待鎖的線程會處于休眠狀態(tài)
  • 需要導入頭文件#import <pthread.h>

@interface mutexDemo()

@property (nonatomic,assign) pthread_mutex_t moneyMutex;
@property (nonatomic,assign) pthread_mutex_t ticketMutex;

@end


@implementation mutexDemo

- (instancetype)init
{
    self = [super init];
    if (self) {
        
        [self __initMutex:&_moneyMutex];
        [self __initMutex:&_ticketMutex];

    }
    return self;
}

//這里必須要傳指針 否則傳進來都是同一個pthread_mutex_t
- (void)__initMutex:(pthread_mutex_t *)mutex
{
    //定義屬性
    pthread_mutexattr_t attr;
    //初始化屬性
    pthread_mutexattr_init(&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_DEFAULT);
    pthread_mutex_init(mutex, &attr);
    //銷毀屬性
    pthread_mutexattr_destroy(&attr);
    
}

- (void)saleTicket
{
    pthread_mutex_lock(&_ticketMutex);
    [super saleTicket];
    pthread_mutex_unlock(&_ticketMutex);
    
}

- (void)saveMoeny
{
    pthread_mutex_lock(&_moneyMutex);
    [super saveMoeny];
    pthread_mutex_unlock(&_moneyMutex);
}

- (void)drawMoney
{
    pthread_mutex_lock(&_moneyMutex);
    [super drawMoney];
    pthread_mutex_unlock(&_moneyMutex);
}
- (void)dealloc
{
    pthread_mutex_destroy(&_moneyMutex);
    pthread_mutex_destroy(&_ticketMutex);
    
}
@end

遞歸鎖

- (instancetype)init
{
    if (self = [super init]) {
        [self __initMutex:&_mutex];
    }
    return self;
}

/**
 線程1:otherTest(+-)
        otherTest(+-)
         otherTest(+-)
 
 線程2:otherTest(等待)
 */

- (void)otherTest
{
    pthread_mutex_lock(&_mutex);
    
    NSLog(@"%s", __func__);
    
    static int count = 0;
    if (count < 10) {
        count++;
        [self otherTest];
    }
    
    pthread_mutex_unlock(&_mutex);
}

NS的鎖基本上是上述鎖的封裝.

dispatch_semaphore_t

  • semaphore叫做”信號量”
  • 信號量的初始值找蜜,可以用來控制線程并發(fā)訪問的最大數(shù)量
  • 信號量的初始值為1饼暑,代表同時只允許1條線程訪問資源稳析,保證線程同步

@interface semaphore()

@property (nonatomic,strong) dispatch_semaphore_t semaphore;

@end

@implementation semaphore

- (instancetype)init
{
    self = [super init];
    if (self) {
        self.semaphore = dispatch_semaphore_create(5);
    }
    return self;
}

- (void)otherTest
{
    for (int i = 0; i<100; i++) {
        [[[NSThread alloc]initWithTarget:self selector:@selector(test) object:nil] start];
    }
}

- (void)test
{
    dispatch_semaphore_wait(self.semaphore, DISPATCH_TIME_FOREVER);
    sleep(2);
    NSLog(@"12345");
    
    dispatch_semaphore_signal(self.semaphore);
}


@end

synchronized

  • @synchronized是對mutex遞歸鎖的封裝
  • 源碼查看:objc4中的objc-sync.mm文件
  • @synchronized(obj)內部會生成obj對應的遞歸鎖洗做,然后進行加鎖、解鎖操作

什么情況使用自旋鎖比較劃算彰居?

- 預計線程等待鎖的時間很短
- 加鎖的代碼(臨界區(qū))經(jīng)常被調用诚纸,但競爭情況很少發(fā)生
- CPU資源不緊張
- 多核處理器

什么情況使用互斥鎖比較劃算?

- 預計線程等待鎖的時間較長
- 單核處理器
- 臨界區(qū)有IO操作
- 臨界區(qū)代碼復雜或者循環(huán)量大
- 臨界區(qū)競爭非常激烈
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末陈惰,一起剝皮案震驚了整個濱河市畦徘,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌抬闯,老刑警劉巖井辆,帶你破解...
    沈念sama閱讀 222,946評論 6 518
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異溶握,居然都是意外死亡杯缺,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,336評論 3 399
  • 文/潘曉璐 我一進店門睡榆,熙熙樓的掌柜王于貴愁眉苦臉地迎上來萍肆,“玉大人,你說我怎么就攤上這事胀屿√链В” “怎么了?”我有些...
    開封第一講書人閱讀 169,716評論 0 364
  • 文/不壞的土叔 我叫張陵宿崭,是天一觀的道長亲铡。 經(jīng)常有香客問我,道長劳曹,這世上最難降的妖魔是什么奴愉? 我笑而不...
    開封第一講書人閱讀 60,222評論 1 300
  • 正文 為了忘掉前任,我火速辦了婚禮铁孵,結果婚禮上锭硼,老公的妹妹穿的比我還像新娘。我一直安慰自己蜕劝,他們只是感情好檀头,可當我...
    茶點故事閱讀 69,223評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著岖沛,像睡著了一般暑始。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上婴削,一...
    開封第一講書人閱讀 52,807評論 1 314
  • 那天廊镜,我揣著相機與錄音,去河邊找鬼唉俗。 笑死嗤朴,一個胖子當著我的面吹牛配椭,可吹牛的內容都是我干的。 我是一名探鬼主播雹姊,決...
    沈念sama閱讀 41,235評論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼股缸,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了吱雏?” 一聲冷哼從身側響起敦姻,我...
    開封第一講書人閱讀 40,189評論 0 277
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎歧杏,沒想到半個月后镰惦,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,712評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡犬绒,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 38,775評論 3 343
  • 正文 我和宋清朗相戀三年陨献,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片懂更。...
    茶點故事閱讀 40,926評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡眨业,死狀恐怖,靈堂內的尸體忽然破棺而出沮协,到底是詐尸還是另有隱情龄捡,我是刑警寧澤,帶...
    沈念sama閱讀 36,580評論 5 351
  • 正文 年R本政府宣布慷暂,位于F島的核電站聘殖,受9級特大地震影響,放射性物質發(fā)生泄漏行瑞。R本人自食惡果不足惜奸腺,卻給世界環(huán)境...
    茶點故事閱讀 42,259評論 3 336
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望血久。 院中可真熱鬧突照,春花似錦、人聲如沸氧吐。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,750評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽筑舅。三九已至座慰,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間翠拣,已是汗流浹背版仔。 一陣腳步聲響...
    開封第一講書人閱讀 33,867評論 1 274
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人蛮粮。 一個月前我還...
    沈念sama閱讀 49,368評論 3 379
  • 正文 我出身青樓背桐,卻偏偏與公主長得像,于是被迫代替她去往敵國和親蝉揍。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 45,930評論 2 361

推薦閱讀更多精彩內容

  • 一畦娄、簡介:多線程在之前進行過一篇詳細的基礎博客 iOS多線程 二又沾、多線程的基礎知識回顧 1.1、iOS中的常見多線...
    IIronMan閱讀 897評論 0 4
  • 基本認識 在計算機的發(fā)展長河中熙卡,為了解決充分能讓 CPU 得到利用杖刷,出現(xiàn)了多線程的概念,其目的就是為了提高 CPU...
    valentizx閱讀 572評論 5 4
  • 目錄:1.為什么要線程安全2.多線程安全隱患分析3.多線程安全隱患的解決方案4.鎖的分類-13種鎖4.1.1OSS...
    二斤寂寞閱讀 1,188評論 0 3
  • 線程安全是怎么產生的 常見比如線程內操作了一個線程外的非線程安全變量驳癌,這個時候一定要考慮線程安全和同步滑燃。 - (v...
    幽城88閱讀 670評論 0 0
  • demo下載 建議一邊看文章,一邊看代碼颓鲜。 聲明:關于性能的分析是基于我的測試代碼來的表窘,我也看到和網(wǎng)上很多測試結果...
    炸街程序猿閱讀 801評論 0 2