? ? ? 在GCD中關(guān)于線程同步的問題,有很多中實(shí)現(xiàn)方式:Group函數(shù),barrier函數(shù),信號(hào)量等;這里只是簡(jiǎn)單研究一下關(guān)于GCD的用法
Group
group函數(shù)的作用:在追加到dispatch_queue中的多個(gè)處理,全部結(jié)束后,想要執(zhí)行結(jié)束的處理
- (void)groupTest1 {
//創(chuàng)建組
dispatch_group_t group =dispatch_group_create();
//獲取全局隊(duì)列
dispatch_queue_tqueue =dispatch_get_global_queue(0,0);
//調(diào)度組的異步請(qǐng)求
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:3];
NSLog(@"下載第一張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:2];
NSLog(@"下載第二張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:4];
NSLog(@"下載第三張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:1];
NSLog(@"下載第四張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:6];
NSLog(@"下載第五張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:5];
NSLog(@"下載第六張圖片");
});
// notify通知當(dāng)所有異步請(qǐng)求完成時(shí) 調(diào)用該函數(shù)
dispatch_group_notify(group, queue, ^{
NSLog(@"刷新UI");
});
}
打印的結(jié)果
2017-06-23 02:16:08.043 GCD的研究[4203:300438]下載第四張圖片
2017-06-23 02:16:09.046 GCD的研究[4203:300450]下載第二張圖片
2017-06-23 02:16:10.046 GCD的研究[4203:300451]下載第一張圖片
2017-06-23 02:16:11.043 GCD的研究[4203:300436]下載第三張圖片
2017-06-23 02:16:12.043 GCD的研究[4203:300457]下載第六張圖片
2017-06-23 02:16:13.043 GCD的研究[4203:300435]下載第五張圖片
2017-06-23 02:16:13.044 GCD的研究[4203:300435]刷新UI
去掉sleep之后的打印結(jié)果,沒次打印的結(jié)果都不相同 ?但是刷新UI一直在最后才打印
2017-06-23 02:17:34.132 GCD的研究[4220:301522]下載第二張圖片
2017-06-23 02:17:34.132 GCD的研究[4220:301506]下載第三張圖片
2017-06-23 02:17:34.132 GCD的研究[4220:301509]下載第四張圖片
2017-06-23 02:17:34.132 GCD的研究[4220:301529]下載第五張圖片
2017-06-23 02:17:34.133 GCD的研究[4220:301530]下載第六張圖片
2017-06-23 02:17:34.132 GCD的研究[4220:301507]下載第一張圖片
2017-06-23 02:17:34.137 GCD的研究[4220:301530]刷新UI
兩者比較,在該異步線程中,任務(wù)是同時(shí)進(jìn)行,notify通知在group任務(wù)完成以后,才會(huì)調(diào)用
wait函數(shù)
- (void)groupTest3 {
//創(chuàng)建組
dispatch_group_tgroup =dispatch_group_create();
//獲取全局隊(duì)列
dispatch_queue_tqueue =dispatch_get_global_queue(0,0);
//調(diào)度組的異步請(qǐng)求
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:3];
NSLog(@"下載第一張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:2];
NSLog(@"下載第二張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:4];
NSLog(@"下載第三張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:1];
NSLog(@"下載第四張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:6];
NSLog(@"下載第五張圖片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:5];
NSLog(@"下載第六張圖片");
});
dispatch_group_wait(group,DISPATCH_TIME_FOREVER);
NSLog(@"刷新UI");
}
DISPATCH_TIME_FOREVER 的打印結(jié)果
DISPATCH_TIME_FOREVER:等待所有完成之后才進(jìn)行下面的操作,任務(wù)沒有完成,會(huì)一直等待;
2017-06-23 02:23:20.459 GCD的研究[4236:303625]下載第四張圖片
2017-06-23 02:23:21.459 GCD的研究[4236:303626]下載第二張圖片
2017-06-23 02:23:22.459 GCD的研究[4236:303639]下載第一張圖片
2017-06-23 02:23:23.459 GCD的研究[4236:303628]下載第三張圖片
2017-06-23 02:23:24.461 GCD的研究[4236:303642]下載第六張圖片
2017-06-23 02:23:25.463 GCD的研究[4236:303641]下載第五張圖片
2017-06-23 02:23:25.463 GCD的研究[4236:303334]刷新UI
/ DISPATCH_TIME_NOW 不用判斷隊(duì)列是否處理完,即不等待,就調(diào)用
打印結(jié)果為:
2017-06-23 02:26:34.723 GCD的研究[4253:305624]刷新UI
2017-06-23 02:26:35.723 GCD的研究[4253:305696]下載第四張圖片
2017-06-23 02:26:36.723 GCD的研究[4253:305668]下載第二張圖片
2017-06-23 02:26:37.726 GCD的研究[4253:305667]下載第一張圖片
2017-06-23 02:26:38.723 GCD的研究[4253:305670]下載第三張圖片
2017-06-23 02:26:39.727 GCD的研究[4253:305698]下載第六張圖片
2017-06-23 02:26:40.727 GCD的研究[4253:305697]下載第五張圖片
Enter和Leave
作用其實(shí)跟group函數(shù)一樣,當(dāng)enter之后,對(duì)應(yīng)的leave出來才會(huì)往下執(zhí)行
- (void)groupTest4
{
dispatch_group_tgroup =dispatch_group_create();
dispatch_queue_tqueue =dispatch_get_global_queue(0,0);
//進(jìn)入隊(duì)列
dispatch_group_enter(group);
dispatch_async(queue, ^{
NSLog(@"下載第三張圖片");
});
dispatch_async(queue, ^{
NSLog(@"下載第四張圖片");
});
dispatch_async(queue, ^{
NSLog(@"下載第二張圖片");
});
dispatch_async(queue, ^{
NSLog(@"下載第一張圖片");
});
dispatch_async(queue, ^{
NSLog(@"下載第五張圖片");
//離開隊(duì)列
dispatch_group_leave(group);
NSLog(@"更新UI");
});
}
打印結(jié)果
2017-06-23 02:44:21.396 GCD的研究[4451:318227]下載第四張圖片
2017-06-23 02:44:21.396 GCD的研究[4451:318226]下載第二張圖片
2017-06-23 02:44:21.396 GCD的研究[4451:318243]下載第三張圖片
2017-06-23 02:44:21.396 GCD的研究[4451:318229]下載第一張圖片
2017-06-23 02:44:21.397 GCD的研究[4451:318227]下載第五張圖片
2017-06-23 02:44:21.397 GCD的研究[4451:318226]更新UI
barrier函數(shù)(柵欄函數(shù))
barrier函數(shù)與dispatch_queue_create函數(shù)生成的concurrent隊(duì)列一起使用
- (void)barrier
{
dispatch_queue_t queue =dispatch_queue_create("1",DISPATCH_QUEUE_CONCURRENT);
dispatch_async(queue, ^{
NSLog(@"----1------%@",[NSThreadcurrentThread]);
});
dispatch_async(queue, ^{
NSLog(@"----2------%@",[NSThreadcurrentThread]);
});
dispatch_barrier_async(queue, ^{
NSLog(@"--barrier--%@",[NSThreadcurrentThread]);
});
dispatch_async(queue, ^{
NSLog(@"----3------%@",[NSThreadcurrentThread]);
});
}
打印結(jié)果
2017-06-23 02:51:05.029 GCD的研究[4675:325885] ----1------{number = 3, name = (null)}
2017-06-23 02:51:05.030 GCD的研究[4675:325873] ----2------{number = 4, name = (null)}
2017-06-23 02:51:05.031 GCD的研究[4675:325873] --barrier--{number = 4, name = (null)}
2017-06-23 02:51:05.031 GCD的研究[4675:325873] ----3------{number = 4, name = (null)}
柵欄函數(shù)的作用和其名字相近,就是在一個(gè)線程隊(duì)列中當(dāng)一個(gè)柵欄的作用
信號(hào)量
dispatch_semaphore_create 創(chuàng)建一個(gè)信號(hào)總量
dispatch_semaphore_signal 發(fā)送一個(gè)信號(hào),讓信號(hào)總量+1
dispatch_semaphore_wait 等待信號(hào),當(dāng)信號(hào)總量少于0的時(shí)候就會(huì)一直等待,否則就可以正常的執(zhí)行,并讓信號(hào)總量-1
根據(jù)這樣的原理,我們可以創(chuàng)建一個(gè)并發(fā)控制來同步任務(wù)和有限資源訪問控制。
- (void)signal
{
dispatch_group_tgroup =dispatch_group_create();
dispatch_semaphore_tsemaphore =dispatch_semaphore_create(10);
dispatch_queue_tqueue =dispatch_get_global_queue(0,0);
for(inti =0; i <100; i++) {
//信號(hào)等待使信號(hào)總量-1,開始為10-1=9繼續(xù)往下執(zhí)行
dispatch_semaphore_wait(semaphore,DISPATCH_TIME_FOREVER);
//將一個(gè)并發(fā)任務(wù)關(guān)聯(lián)到Group
dispatch_group_async(group, queue, ^{
NSLog(@"%i",i);
sleep(2);
//發(fā)送一個(gè)信號(hào)信號(hào)總量+1如果+1前信號(hào)總量小于1了即刻有可以開始執(zhí)行之前的等待位置
dispatch_semaphore_signal(semaphore);
});
}
//等待group相關(guān)的所有任務(wù)執(zhí)行完成才往下走
dispatch_group_wait(group,DISPATCH_TIME_FOREVER);
NSLog(@"更新UI");
}
打印結(jié)果顯示,每次打印十個(gè),待所有任務(wù)執(zhí)行完成 更新UI
其實(shí)類似于NSOperationQueue中設(shè)置最大并發(fā)數(shù);