在iOS開發(fā)的道路上,多線程的重要性不言而喻. 大部分我們都停留在基礎(chǔ)的使用上面.缺乏高級(jí)應(yīng)用. 缺乏提升,是因?yàn)槲覀兠鎸?duì)他太少,復(fù)雜的事情重復(fù)做,復(fù)雜的事務(wù)基礎(chǔ)化. 差距就是這樣拉開了 ------- 偉大的樓主
言歸正傳: 今天講講GCD的高級(jí)應(yīng)用之信號(hào)量篇
一, 信號(hào)量的本質(zhì):
信號(hào)量的本質(zhì)是數(shù)據(jù)操作鎖, 它本身不具有數(shù)據(jù)交換的功能,而是通過控制其他的通信資源來實(shí)現(xiàn)進(jìn)程間通信，它本身只是一種外部資源的標(biāo)識(shí)。信號(hào)量在此過程中負(fù)責(zé)數(shù)據(jù)操作的互斥境肾、同步等功能.
二: 信號(hào)量的工作原理
由于信號(hào)量只能進(jìn)行兩種操作等待和發(fā)送信號(hào)百姓，即P(sv)和V(sv),他們的行為是這樣的：
P(sv)：如果sv的值大于零翎迁，就給它減1巷帝；如果它的值為零往湿，就掛起該進(jìn)程的執(zhí)行
V(sv)：如果有其他進(jìn)程因等待sv而被掛起纷跛，就讓它恢復(fù)運(yùn)行喻括，如果沒有進(jìn)程因等待sv而掛起，就給它加1.
舉個(gè)例子贫奠，就是 兩個(gè)進(jìn)程共享信號(hào)量sv唬血，一旦其中一個(gè)進(jìn)程執(zhí)行了P(sv)操作，它將得到信號(hào)量唤崭，并可以進(jìn)入臨界區(qū)拷恨，使sv減1。而第二個(gè)進(jìn)程將被阻止進(jìn)入臨界區(qū)谢肾，因?yàn)?當(dāng)它試圖執(zhí)行P(sv)時(shí)腕侄，sv為0，它會(huì)被掛起以等待第一個(gè)進(jìn)程離開臨界區(qū)域并執(zhí)行V(sv)釋放信號(hào)量芦疏，這時(shí)第二個(gè)進(jìn)程就可以恢復(fù)執(zhí)行冕杠。
三: iOS中GCD的信號(hào)量函數(shù)解析:
dispatch_semaphore_t semaphore = dispatch_semaphore_create(2);
這行代碼創(chuàng)建了一個(gè)信號(hào)量,同時(shí)指明了最多有2個(gè)資源可以訪問該"臨界區(qū)域"
dispatch_semaphore_signal(semaphore)
這行代碼 提高信號(hào)量 , 信號(hào)量計(jì)數(shù) + 1
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
這行代碼 降低信號(hào)量 , 信號(hào)量計(jì)數(shù) - 1
特別注意 當(dāng)信號(hào)為0(零),在執(zhí)行 dispatch_semaphore_wait 語句時(shí),信號(hào)量計(jì)數(shù)小于0 ,阻塞當(dāng)前線程.
四: GCD的信號(hào)量應(yīng)用場(chǎng)景: 控制最大并發(fā)量, 控制資源的同步訪問,如數(shù)據(jù)訪問,網(wǎng)絡(luò)同步加載.
例如我有這樣的一段代碼,假設(shè)需求是控制兩個(gè)網(wǎng)絡(luò)的執(zhí)行順序 如想讓請(qǐng)求一完成之后,在進(jìn)行網(wǎng)絡(luò)請(qǐng)求二,然后在進(jìn)行網(wǎng)絡(luò)請(qǐng)求N (實(shí)現(xiàn)的方式有多種多樣)在此處主要討論GCD semaphore 信號(hào)量的使用:
首先大家看看這段代碼帶來的問題
-(void)testSemaphore{
NSLog(@"current1:%@",[NSThread currentThread]);
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
[AKkaHttpTool Post:@"https://api.douban.com/v2/book/1220562" parameters:@{@"":@""} success:^(id _Nullable responseObject) {
dispatch_semaphore_signal(semaphore);
} failure:^(NSError * _Nullable error, NSInteger statusCode) {
dispatch_semaphore_signal(semaphore);
}];
NSLog(@"你會(huì)來這兒?jiǎn)?");
NSLog(@"current1:%@",[NSThread currentThread]);
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); //等待信號(hào),當(dāng)信號(hào)總量少于0 的時(shí)候就會(huì)一直等待 ,否則就可以正常的執(zhí)行,并讓信號(hào)總量-1
NSLog(@"你會(huì)來這兒?jiǎn)?");
[AKkaHttpTool Post:@"https://api.douban.com/v2/book/1220562" parameters:@{@"":@""} success:^(id _Nullable responseObject) {
NSLog(@"resqueue2:");
} failure:^(NSError * _Nullable error, NSInteger statusCode) {
}];
}
下面我用一張截圖進(jìn)行說明,主要是用于說明 dispatch_semaphore_wait 會(huì)阻塞當(dāng)前線程
接下來這三個(gè)網(wǎng)絡(luò)請(qǐng)求使用GCD信號(hào)量實(shí)現(xiàn)同步,并且不阻塞主線程
- (IBAction)gcd2:(id)sender {
dispatch_queue_t queue = dispatch_queue_create("AkSemaphore", NULL);
dispatch_async(queue, ^{
NSLog(@"current1:%@",[NSThread currentThread]);
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
[AKkaHttpTool Post:@"https://api.douban.com/v2/book/1220562" parameters:@{@"":@""} success:^(id _Nullable responseObject) {
dispatch_semaphore_signal(semaphore);
NSLog(@"resqueue1:");
} failure:^(NSError * _Nullable error, NSInteger statusCode) {
dispatch_semaphore_signal(semaphore);
}];
NSLog(@"你會(huì)來這兒?jiǎn)?");
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); //等待信號(hào),當(dāng)信號(hào)總量少于0 的時(shí)候就會(huì)一直等待 ,否則就可以正常的執(zhí)行,并讓信號(hào)總量-1
NSLog(@"你會(huì)來這兒?jiǎn)?");
[AKkaHttpTool Post:@"https://api.douban.com/v2/book/1220562" parameters:@{@"":@""} success:^(id _Nullable responseObject) {
NSLog(@"resqueue2:");
dispatch_semaphore_signal(semaphore);
} failure:^(NSError * _Nullable error, NSInteger statusCode) {
dispatch_semaphore_signal(semaphore);
}];
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); //等待信號(hào),當(dāng)信號(hào)總量少于0 的時(shí)候就會(huì)一直等待 ,否則就可以正常的執(zhí)行,并讓信號(hào)總量-1
NSLog(@"你會(huì)來這兒?jiǎn)?");
[AKkaHttpTool Post:@"https://api.douban.com/v2/book/1220562" parameters:@{@"":@""} success:^(id _Nullable responseObject) {
NSLog(@"resqueue3:");
} failure:^(NSError * _Nullable error, NSInteger statusCode) {
}];
});
}
接下來講一下控制網(wǎng)絡(luò)的并發(fā)訪問 :
假如現(xiàn)在有一個(gè)這樣的需求,需要先下載50張圖片, 一般異步會(huì)開啟新的線程,但過多的線程 數(shù)與項(xiàng)目的性能是成反比的 . 所以控制并發(fā),提高性能則尤為重要 : 實(shí)例代碼如下
- (void)testGCD3{
dispatch_semaphore_t semaphore = dispatch_semaphore_create(5);
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
for (int i=0;i<100 ; i++) {
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
dispatch_async(queue, ^{
NSLog(@"i = %d",i);
//此處模擬一個(gè) 異步下載圖片的操作
sleep(2);
dispatch_semaphore_signal(semaphore);
});
}
}
代碼講解如下圖:
