2018年07月18日 16:34:38 hbblzjy 閱讀數:1382html
版權聲明:本文爲博主原創文章,未經博主容許不得轉載。 https://blog.csdn.net/hbblzjy/article/details/81100453數組
//線程組解決同一個界面須要請求多個接口數據,當所有請求完成後,再進入主線程刷新界面緩存
/*網絡
這種問題使用 dispatch_group_enter(grpupE);來解決,dispatch_group_enter 和 dispatch_group_leave 必需要成對出現;多線程
dispatch_group_enter : 使用一種手動的方式將另一個 block 以不一樣於 dispatch_group_async 的方式添加到線程組中。在異步任務開始以前調用;併發
dispatch_group_leave : 手動指示一個 block 塊執行完畢。以一種不用於 dispatch_group_async 的方式離開線程組,在異步任務執行完成以後調用;異步
若是不添加enter、leave,那麼將會先執行完全部的外圍方法操做,而後纔會執行block中的內容,這樣就沒法實現數據所有完成後再刷新主界面的操做。其實這不難理解,好比block是在A方法中,block的執行,都是在A方法執行完後纔會執行的async
*/函數
//1、不開啓子線程的線程組簡化方式url
dispatch_group_t group = dispatch_group_create();
//模擬網絡請求1
dispatch_group_enter(group);
//實際運用時,用網絡請求的方法代替下面的內容,不要忘記leave 異步
dispatch_async(dispatch_get_global_queue(0, 0), ^{
for (int i = 0; i < 5; i++) {
[NSThread sleepForTimeInterval:1];
NSLog(@"當前線程:%@,是不是主線程:%@...1111···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//當前線程:<NSThread: 0x60000027ef40>{number = 3, name = (null)},是不是主線程:否...1111···0
}
dispatch_group_leave(group);
});
NSLog(@"當前線程:%@,是不是主線程:%@...4444···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//當前線程:<NSThread: 0x604000071d40>{number = 1, name = main},是不是主線程:是...4444···
//模擬網絡請求2
dispatch_group_enter(group);
//實際運用時,用網絡請求的方法代替下面的內容,不要忘記leave 異步
dispatch_async(dispatch_get_global_queue(0, 0), ^{
for (int i = 0; i < 5; i++) {
[NSThread sleepForTimeInterval:1];
NSLog(@"當前線程:%@,是不是主線程:%@...2222···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//當前線程:<NSThread: 0x604000272540>{number = 4, name = (null)},是不是主線程:否...2222···0
}
dispatch_group_leave(group);
});
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
NSLog(@"當前線程:%@,是不是主線程:%@...3333···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//當前線程:<NSThread: 0x604000071d40>{number = 1, name = main},是不是主線程:是...3333···
});
結果如圖:
//2、開啓子線程的線程組
//一個併發隊列
dispatch_queue_t queueE = dispatch_queue_create("group.queue", DISPATCH_QUEUE_CONCURRENT);
//一個線程組
dispatch_group_t groupE = dispatch_group_create();
dispatch_group_async(groupE, queueE, ^{
NSLog(@"當前線程:%@,是不是主線程:%@...1111···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//當前線程:<NSThread: 0x60400026a540>{number = 3, name = (null)},是不是主線程:否...1111···
//模擬網絡請求1
dispatch_group_enter(groupE);
//實際運用時,用網絡請求的方法代替下面的內容,不要忘記leave 異步
dispatch_async(dispatch_get_global_queue(0, 0), ^{
for (int i = 0; i < 5; i++) {
[NSThread sleepForTimeInterval:1];
NSLog(@"當前線程:%@,是不是主線程:%@...2222···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//當前線程:<NSThread: 0x60400026a540>{number = 3, name = (null)},是不是主線程:否...2222···0
}
dispatch_group_leave(groupE);
});
});
dispatch_group_async(groupE, queueE, ^{
NSLog(@"當前線程:%@,是不是主線程:%@...3333···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//當前線程:<NSThread: 0x60400026a900>{number = 4, name = (null)},是不是主線程:否...3333···
//模擬網絡請求2
dispatch_group_enter(groupE);
//實際運用時,用網絡請求的方法代替下面的內容,不要忘記leave 異步
dispatch_async(dispatch_get_global_queue(0, 0), ^{
for (int i = 0; i < 5; i++) {
[NSThread sleepForTimeInterval:1];
NSLog(@"當前線程:%@,是不是主線程:%@...4444···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//當前線程:<NSThread: 0x60000026cac0>{number = 5, name = (null)},是不是主線程:否...4444···0
}
dispatch_group_leave(groupE);
});
});
dispatch_group_async(groupE, queueE, ^{
NSLog(@"當前線程:%@,是不是主線程:%@...5555···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//當前線程:<NSThread: 0x60000026cac0>{number = 5, name = (null)},是不是主線程:否...5555···
//模擬網絡請求3
dispatch_group_enter(groupE);
//實際運用時,用網絡請求的方法代替下面的內容,不要忘記leave 異步
dispatch_async(dispatch_get_global_queue(0, 0), ^{
for (int i = 0; i < 5; i++) {
[NSThread sleepForTimeInterval:1];
NSLog(@"當前線程:%@,是不是主線程:%@...6666···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//當前線程:<NSThread: 0x60400026a900>{number = 4, name = (null)},是不是主線程:否...6666···0
}
dispatch_group_leave(groupE);
});
});
// dispatch_group_notify(groupE, queueE, ^{
// NSLog(@"當前線程:%@,是不是主線程:%@...7777···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//當前線程:<NSThread: 0x60400026a540>{number = 3, name = (null)},是不是主線程:否...7777···
// dispatch_async(dispatch_get_main_queue(), ^{
// NSLog(@"當前線程:%@,是不是主線程:%@...8888···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//當前線程:<NSThread: 0x604000069700>{number = 1, name = main},是不是主線程:是...8888···
// });
// });
//簡化上一種形式
dispatch_group_notify(groupE, dispatch_get_main_queue(), ^{
NSLog(@"當前線程:%@,是不是主線程:%@...7777···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//當前線程:<NSThread: 0x604000071d40>{number = 1, name = main},是不是主線程:是...7777···
});
結果如圖:
當取消了enter和leave語句後:
版權全部,轉載請註明出處,謝謝~~~不喜勿噴!謝謝
【多線程】多個請求完成之後再執行其餘操做
大基本功 關注
2018.06.19 14:46 字數 62 閱讀 24評論 0喜歡 0
有時會出現這樣一種狀況,好比某個頁面需請求多個接口獲取數據後刷新UI界面,直接上代碼使用GCD完成
1.完成數據後回調
- (void)getAdHotTopDataBaseRequestisScu:(void(^)(BOOL isScu))requestisScu{
WEAKBLOCK;
[self.topAddArray removeAllObjects];
NSString *urlStr = @"Ad/fx_top";
[LFNetWorkManager requestDataBaseWithURLByGET:urlStr parameters:nil isWithToken:NO completed:^(id responseObject) {
if([responseObject[@"code"] integerValue] == 200){
[ToosZFJ readAndWriteHomeListDataBase:responseObject fileName:[urlStr stringFromMD5] completed:nil];//這個是我寫的緩存數據的方法
NSArray *data = responseObject[@"data"];
for (NSDictionary *dict in data) {
ADModel *model = [[ADModel alloc]init];
[model setValuesForKeysWithDictionary:dict];
model.mid = dict[@"id"];
if([dict[@"circle"] integerValue] == 1){
//話題
}else{
//頭部輪播廣告
[weakSelf.topAddArray addObject:model];
}
}
}else{
[weakSelf SHOWPrompttext:responseObject[@"message"]];
}
if(requestisScu){
requestisScu((200 == [responseObject[@"code"] integerValue])?YES:NO);
}
}];
}
2.發起異步請求並監聽
- (void)startAllRequest{
[self showMBProgressHUDLoding:nil];
dispatch_group_t group = dispatch_group_create();
dispatch_queue_t queue= dispatch_get_global_queue(0, 0);
// 廣告數組
dispatch_group_enter(group);
dispatch_group_async(group, queue, ^{
[self getAdHotTopDataBaseRequestisScu:^(BOOL isScu) {
dispatch_group_leave(group);
}];
});
// 個人關注
dispatch_group_enter(group);
dispatch_group_async(group, queue, ^{
[self getDataOfSOurcesFoucesRequestisScu:^(BOOL isScu) {
dispatch_group_leave(group);
}];
});
// 推薦比賽
dispatch_group_enter(group);
dispatch_group_async(group, queue, ^{
[self getDataSourcesCompareRequestisScu:^(BOOL isScu) {
dispatch_group_leave(group);
}];
});
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
[weakSelf RemoveMBProgressHUDLoding:nil];
[weakSelf.collectionView reloadData];
[weakSelf endRefreshingForTableView:weakSelf.collectionView];
});
}
使用第三方庫來實現
https://www.cnblogs.com/sundaysgarden/articles/10365574.html
iOS GCD中級篇 - dispatch_semaphore(信號量)的理解及使用
理解這個概念以前,先拋出一個問題
問題描述:
假設如今系統有兩個空閒資源能夠被利用,但同一時間卻有三個線程要進行訪問,這種狀況下,該如何處理呢?
或者
咱們要下載不少圖片,併發異步進行,每一個下載都會開闢一個新線程,但是咱們又擔憂太多線程確定cpu吃不消,那麼咱們這裏也能夠用信號量控制一下最大開闢線程數。
定義:
一、信號量:就是一種可用來控制訪問資源的數量的標識,設定了一個信號量,在線程訪問以前,加上信號量的處理,則可告知系統按照咱們指定的信號量數量來執行多個線程。
其實,這有點相似鎖機制了,只不過信號量都是系統幫助咱們處理了,咱們只須要在執行線程以前,設定一個信號量值,而且在使用時,加上信號量處理方法就好了。
二、信號量主要有3個函數,分別是:
1 2 3 4 5 6 7 8 |
//建立信號量,參數:信號量的初值,若是小於0則會返回NULL dispatch_semaphore_create(信號量值)
//等待下降信號量 dispatch_semaphore_wait(信號量,等待時間)
//提升信號量 dispatch_semaphore_signal(信號量) |
注意,正常的使用順序是先下降而後再提升,這兩個函數一般成對使用。 (具體可參考下面的代碼示例)
三、那麼就開頭提的問題,咱們用代碼來解決
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 |
-(void)dispatchSignal{ //crate的value表示,最多幾個資源可訪問 dispatch_semaphore_t semaphore = dispatch_semaphore_create(2); dispatch_queue_t quene = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
//任務1 dispatch_async(quene, ^{ dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); NSLog(@"run task 1"); sleep(1); NSLog(@"complete task 1"); dispatch_semaphore_signal(semaphore); });<br> //任務2 dispatch_async(quene, ^{ dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); NSLog(@"run task 2"); sleep(1); NSLog(@"complete task 2"); dispatch_semaphore_signal(semaphore); });<br> //任務3 dispatch_async(quene, ^{ dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); NSLog(@"run task 3"); sleep(1); NSLog(@"complete task 3"); dispatch_semaphore_signal(semaphore); }); } |
執行結果:
總結:因爲設定的信號值爲2,先執行兩個線程,等執行完一個,纔會繼續執行下一個,保證同一時間執行的線程數不超過2。
這裏咱們擴展一下,假設咱們設定信號值=1
1 |
dispatch_semaphore_create(1)<br><br> |
那麼結果就是:
若是設定信號值=3
1 |
dispatch_semaphore_create(3)<br><br> |
那麼結果就是:
其實設定爲3,就是不限制線程執行了,由於一共才只有3個線程。
以上只是舉的比較簡單的例子,在一些特殊場景下,合理利用信號量去控制,可以方便的解決咱們的難題哦
NSOperationQueue *queue = [[NSOperationQueue alloc]init]; // 設置最大線程數 queue.maxConcurrentOperationCount = 5; // 建立一個A操做 NSBlockOperation *operationA = [NSBlockOperation blockOperationWithBlock:^{ for (int i = 0; i<10; i++) { NSLog(@"i的值是:%d",i); } }]; // 建立一個B操做 NSBlockOperation *operationB = [NSBlockOperation blockOperationWithBlock:^{ for (int j = 0; j<20; j++) { NSLog(@"j的值是:%d",j); } }]; // 添加依賴 B要在A打印完在進行打印 因此是B依賴於A 那麼只須要添加以下代碼便可完成 [operationB addDependency:operationA]; // 分別加入到隊列中 [queue addOperation:operationA]; [queue addOperation:operationB]; //YES會阻塞當前線程 // [queue addOperations:@[operationA, operationB] waitUntilFinished:NO];