1.多任務請求接口,完成后,在刷新數據,常用方法
2018年07月18日 16:34:38 hbblzjy 閱讀數：1382
版權聲明：本文為博主原創文章，未經博主允許不得轉載。 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方法執行完后才會執行的
*/
//1、不開啟子線程的線程組簡化方式
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];
});
}
2.多任務,請求數據,完成后的第二種方法, 簡單美姊姊
使用第三方庫來實現
https://www.cnblogs.com/sundaysgarden/articles/10365574.html
3.使用dispatch_semaphore_t控制多個線程使用系統資源
iOS GCD中級篇 - dispatch_semaphore（信號量）的理解及使用
理解這個概念之前，先拋出一個問題
問題描述：
假設現在系統有兩個空閑資源可以被利用，但同一時間卻有三個線程要進行訪問，這種情況下，該如何處理呢？
或者
我們要下載很多圖片，並發異步進行，每個下載都會開辟一個新線程，可是我們又擔心太多線程肯定cpu吃不消，那么我們這里也可以用信號量控制一下最大開辟線程數。
定義：
1、信號量：就是一種可用來控制訪問資源的數量的標識，設定了一個信號量，在線程訪問之前，加上信號量的處理，則可告知系統按照我們指定的信號量數量來執行多個線程。
其實，這有點類似鎖機制了，只不過信號量都是系統幫助我們處理了，我們只需要在執行線程之前，設定一個信號量值，並且在使用時，加上信號量處理方法就行了。
2、信號量主要有3個函數，分別是：
| 1 2 3 4 5 6 7 8 |
//創建信號量，參數：信號量的初值，如果小於0則會返回NULL dispatch_semaphore_create（信號量值）
//等待降低信號量 dispatch_semaphore_wait（信號量，等待時間）
//提高信號量 dispatch_semaphore_signal(信號量) |
注意，正常的使用順序是先降低然后再提高，這兩個函數通常成對使用。 （具體可參考下面的代碼示例）
3、那么就開頭提的問題，我們用代碼來解決
| 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個線程。
以上只是舉的比較簡單的例子，在一些特殊場景下，合理利用信號量去控制，能夠方便的解決我們的難題哦
4. NSOperationQueue
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];作者：一葉傾城亂
鏈接：https://www.jianshu.com/p/56f4f2cf8cae
來源：簡書
簡書著作權歸作者所有，任何形式的轉載都請聯系作者獲得授權並注明出處。