用GCD線程組與GCD信號量將非同步線程轉換為同步線程

来源:http://www.cnblogs.com/goodboy-heyang/archive/2016/03/15/5277910.html
-Advertisement-
Play Games

有時候我們會碰到這樣子的一種情形: 同時獲取兩個網路請求的數據,但是網路請求是非同步的,我們需要獲取到兩個網路請求的數據之後才能夠進行下一步的操作,這個時候,就是線程組與信號量的用武之地了. 列印結果： 2016-03-15 04:01:53.279 NetWorking[83611:1508240]


有時候我們會碰到這樣子的一種情形:

同時獲取兩個網路請求的數據,但是網路請求是非同步的,我們需要獲取到兩個網路請求的數據之後才能夠進行下一步的操作,這個時候,就是線程組與信號量的用武之地了.

 1 #import "ViewController.h"
 2 #import <AFNetworking.h>
 3 
 4 
 5 @interface ViewController ()
 6 
 7 @end
 8 
 9 @implementation ViewController
10 
11 - (void)viewDidLoad {
12     [super viewDidLoad];
13     [self getNetworkingData];
14 }
15 
16 - (void)getNetworkingData{
17     NSString *appIdKey = @"8781e4ef1c73ff20a180d3d7a42a8c04";
18     NSString* urlString_1 = @"http://api.openweathermap.org/data/2.5/weather";
19     NSString* urlString_2 = @"http://api.openweathermap.org/data/2.5/forecast/daily";
20     NSDictionary* dictionary =@{@"lat":@"40.04991291",
21                                 @"lon":@"116.25626162",
22                                 @"APPID" : appIdKey};
23     // 創建組
24     dispatch_group_t group = dispatch_group_create();
25     // 將第一個網路請求任務添加到組中
26     dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
27         // 創建信號量
28         dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
29         // 開始網路請求任務
30         AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
31         [manager GET:urlString_1
32           parameters:dictionary
33             progress:nil
34              success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
35                  NSLog(@"成功請求數據1:%@",[responseObject class]);
36                  // 如果請求成功，發送信號量
37                  dispatch_semaphore_signal(semaphore);
38              } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
39                  NSLog(@"失敗請求數據");
40                  // 如果請求失敗，也發送信號量
41                  dispatch_semaphore_signal(semaphore);
42              }];
43         // 在網路請求任務成功之前，信號量等待中
44         dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
45     });
46     // 將第二個網路請求任務添加到組中
47     dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
48         // 創建信號量
49         dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
50         // 開始網路請求任務
51         AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
52         [manager GET:urlString_2
53           parameters:dictionary
54             progress:nil
55              success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
56                  NSLog(@"成功請求數據2:%@",[responseObject class]);
57                  // 如果請求成功，發送信號量
58                  dispatch_semaphore_signal(semaphore);
59              } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
60                  NSLog(@"失敗請求數據");
61                  // 如果請求失敗，也發送信號量
62                  dispatch_semaphore_signal(semaphore);
63              }];
64         // 在網路請求任務成功之前，信號量等待中
65         dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
66     });
67     dispatch_group_notify(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
68         NSLog(@"完成了網路請求，不管網路請求失敗了還是成功了。");
69     });
70 }
71 
72 @end

列印結果：

2016-03-15 04:01:53.279 NetWorking[83611:1508240] 成功請求數據1:__NSCFDictionary
2016-03-15 04:01:53.280 NetWorking[83611:1508240] 成功請求數據2:__NSCFDictionary
2016-03-15 04:01:53.281 NetWorking[83611:1508287] 完成了網路請求，不管網路請求失敗了還是成功了。

為了和上面形成對比，我特地將所有的信號量的代碼全部去除，但是保留GCD線程組的使用，然後運行看列印結果。

 1 #import "ViewController.h"
 2 #import <AFNetworking.h>
 3 
 4 
 5 @interface ViewController ()
 6 
 7 @end
 8 
 9 @implementation ViewController
10 
11 - (void)viewDidLoad {
12     [super viewDidLoad];
13     [self getNetworkingData];
14 }
15 
16 - (void)getNetworkingData{
17     NSString *appIdKey = @"8781e4ef1c73ff20a180d3d7a42a8c04";
18     NSString* urlString_1 = @"http://api.openweathermap.org/data/2.5/weather";
19     NSString* urlString_2 = @"http://api.openweathermap.org/data/2.5/forecast/daily";
20     NSDictionary* dictionary =@{@"lat":@"40.04991291",
21                                 @"lon":@"116.25626162",
22                                 @"APPID" : appIdKey};
23     // 創建組
24     dispatch_group_t group = dispatch_group_create();
25     // 將第一個網路請求任務添加到組中
26     dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
27         // 開始網路請求任務
28         AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
29         [manager GET:urlString_1
30           parameters:dictionary
31             progress:nil
32              success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
33                  NSLog(@"成功請求數據1:%@",[responseObject class]);
34              } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
35                  NSLog(@"失敗請求數據");
36              }];
37     });
38     // 將第二個網路請求任務添加到組中
39     dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
40         // 開始網路請求任務
41         AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
42         [manager GET:urlString_2
43           parameters:dictionary
44             progress:nil
45              success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
46                  NSLog(@"成功請求數據2:%@",[responseObject class]);
47              } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
48                  NSLog(@"失敗請求數據");
49              }];
50     });
51     dispatch_group_notify(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
52         NSLog(@"完成了網路請求，不管網路請求失敗了還是成功了。");
53     });
54 }
55 
56 @end

列印結果：

2016-03-15 04:05:09.378 NetWorking[83698:1510242] 完成了網路請求，不管網路請求失敗了還是成功了。
2016-03-15 04:05:10.185 NetWorking[83698:1510096] 成功請求數據1:__NSCFDictionary
2016-03-15 04:05:10.186 NetWorking[83698:1510096] 成功請求數據2:__NSCFDictionary

看到這個列印結果，我們視乎有點看不懂了，難道notify線程組沒用了？notify不是會在組中的非同步任務執行完畢了才會執行麽？這是什麼情況？

下麵我在上面的代碼基礎上添加了第33、38、39、49、54、55行代碼，然後我們再來看看列印結果：

 1 #import "ViewController.h"
 2 #import <AFNetworking.h>
 3 
 4 
 5 @interface ViewController ()
 6 
 7 @end
 8 
 9 @implementation ViewController
10 
11 - (void)viewDidLoad {
12     [super viewDidLoad];
13     [self getNetworkingData];
14 }
15 
16 - (void)getNetworkingData{
17     NSString *appIdKey = @"8781e4ef1c73ff20a180d3d7a42a8c04";
18     NSString* urlString_1 = @"http://api.openweathermap.org/data/2.5/weather";
19     NSString* urlString_2 = @"http://api.openweathermap.org/data/2.5/forecast/daily";
20     NSDictionary* dictionary =@{@"lat":@"40.04991291",
21                                 @"lon":@"116.25626162",
22                                 @"APPID" : appIdKey};
23     // 創建組
24     dispatch_group_t group = dispatch_group_create();
25     // 將第一個網路請求任務添加到組中
26     dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
27         // 開始網路請求任務
28         AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
29         [manager GET:urlString_1
30           parameters:dictionary
31             progress:nil
32              success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
33                  NSLog(@"%@",[NSThread currentThread]);
34                  NSLog(@"成功請求數據1:%@",[responseObject class]);
35              } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
36                  NSLog(@"失敗請求數據");
37              }];
38         NSLog(@"%@",[NSThread currentThread]);
39         NSLog(@"AFN網路請求框架請求完畢");
40     });
41     // 將第二個網路請求任務添加到組中
42     dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
43         // 開始網路請求任務
44         AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
45         [manager GET:urlString_2
46           parameters:dictionary
47             progress:nil
48              success:^(NSURLSessionDataTask * _Nonnull task, id  _Nullable responseObject) {
49                  NSLog(@"%@",[NSThread currentThread]);
50                  NSLog(@"成功請求數據2:%@",[responseObject class]);
51              } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
52                  NSLog(@"失敗請求數據");
53              }];
54         NSLog(@"%@",[NSThread currentThread]);
55         NSLog(@"AFN網路請求框架請求完畢");
56     });
57     dispatch_group_notify(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
58         NSLog(@"完成了網路請求，不管網路請求失敗了還是成功了。");
59     });
60 }
61 
62 @end

列印結果(溫馨提示：請求數據可能會出現失敗，因為這個網路請求的url是國外的伺服器，但是沒關係，不要在意這個細節，列印順序還是一樣的)：

2016-03-15 04:30:07.406 NetWorking[84306:1523047] <NSThread: 0x7fc258725e10>{number = 2, name = (null)}
2016-03-15 04:30:07.406 NetWorking[84306:1523048] <NSThread: 0x7fc258406100>{number = 3, name = (null)}
2016-03-15 04:30:07.407 NetWorking[84306:1523047] AFN網路請求框架請求完畢
2016-03-15 04:30:07.407 NetWorking[84306:1523048] AFN網路請求框架請求完畢
2016-03-15 04:30:07.407 NetWorking[84306:1523075] 完成了網路請求，不管網路請求失敗了還是成功了。
2016-03-15 04:30:08.239 NetWorking[84306:1523016] <NSThread: 0x7fc258507af0>{number = 1, name = main}
2016-03-15 04:30:08.239 NetWorking[84306:1523016] 成功請求數據1:__NSCFDictionary
2016-03-15 04:30:08.240 NetWorking[84306:1523016] <NSThread: 0x7fc258507af0>{number = 1, name = main}
2016-03-15 04:30:08.240 NetWorking[84306:1523016] 成功請求數據2:__NSCFDictionary

 

總結：網路請求然後處理響應數據是個耗時的操作，也是我們開發中常見的一種情形，在網路請求以及處理響應數據操作完畢之後我們在執行別的操作這樣的過程也是我們開發中常見的情形。根據第三部分代碼(沒有使用信號量的代碼)列印結果的順序，我們可以知道，網路請求的任務是提交給子線程非同步處理了，網路請求這樣的任務也就快速執行完畢了，但是網路請求是一個任務，處理收到的網路響應又是一個任務，註意不要把這兩個過程混為一談。而收到網路響應以及處理返迴響應的數據並不是在子線程中執行的，我們通過在回調響應處理的block(比如48~53行之間就有兩個block)中列印當前線程，會發現回調響應處理的block是在主線程中被執行的。

如果讀者很熟悉block回調這種通信機制的話，就不難理解，這個回調響應的block真正被調用執行的地方應該是AFN框架的底層代碼，而這部分代碼顯然是在主線程中執行的。

 

那麼，這時候，如果我們需要確定這個主線程中收到網路響應的數據被處理操作結束之後，才最後執行我們需要最後的操作的話，僅僅依靠線程組看來是不夠的，所以很少用到的GCD信號量就有了用武之地了。

當然，以上代碼如果不用GCD線程組，只用GCD的信號量來處理，也是可以的，這個就留給大家自己探究吧。

 

最後再簡化總結一下：信號量的使用前提是，想清楚你需要處理哪個線程等待，又要哪個線程繼續執行，然後使用信號量。

　　比如上面的AFN網路請求的示例，block回調是在main主線程中執行的，而get請求是在自己創建的非同步子線程中執行的。所以按照需求，就需要自己創建的非同步子線程等待main主線程中的block執行完了之後再執行。所以非同步子線程需要信號量wait，main主線程就設置signal發送信號量。

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Long類型比較之equals與==
    在判斷兩個Long型數據是否相等的時候遇到了一個問題。 <! more 使用“==”的疑問 兩個Long型的ID之間的比較，結果卻是false。 再看一個 同是Long型，同是 ,為什麼結果不一樣呢？ 看看源代碼： java private static class LongCache { priv
  • 【代碼筆記】關於UIFont的一些define
    一，效果圖。 二，工程圖。 三，代碼。 RootViewController.h   RootViewController.m   Utils.h   Utils.m  
  • android support的作用及其常見錯誤的解決
    解決方法： 添加資源庫，針對上面的例子，AppCompat這個是v7里的，所以缺少的是v7的資源。從sdk去獲取，路徑是sdk\extras\android\support\v7\appcompat，把這個library通過eclipse導入(import)。然後之前的項目添加該lib，再clean
  • swift 接水果游戲ios源碼
    初學swift，寫來練手的，游戲很簡單 ，顧名思義就是接水果 ，菠蘿不能接，接到一個水果得一分，接到菠蘿扣五分，漏一個水果扣一分，初始分0分，當分數低於0分 就Game Over了，暫時適用5s的模擬器，因為初學，有問題歡迎大家指出 ^。^   源碼下載：http://code.662p.com/l
  • 分享一個仿就看天氣應用源碼
    作者xcc3641，源碼SeeWeather，就看天氣——是一款遵循Material Design風格的只看天氣的APP。無流氓許可權，無自啟，xxx，用最少的許可權做最優的體驗。卡片展現（當前天氣情況，未來幾小時天氣情況，生活建議，一周七天概況）補全城市（第一版本因為自己偷懶所以城市有缺陷對不起各位）
  • 春秋旅行安卓客戶端源碼項目
    春秋旅行安卓客戶端源碼，這是一款高度模仿春秋旅行app開發的一款應用，通過抓包工具獲取到的介面，希望大家能夠喜歡，並且對大家的學習能夠有所幫助。 源碼下載：http://code.662p.com/view/12837.html <ignore_js_op> <ignore_js_op>  詳細說明
  • iOS中的事件傳遞和響應者鏈條
    本文轉自：http://www.linuxidc.com/Linux/2015-08/121270.htm 6.橙2都滿足最上面兩個條件，遍歷子控制項，先取出紅3 7.紅3不滿足條件2，取出藍3 8.藍3也不滿足條件2，最後最合適的控制項是橙2 找到合適的控制項之後就要進行響應了，這裡先介紹一下響應者鏈條
  • Android開發遇到的異常及解決辦法
    Android開發遇到的錯誤及解決方法1. Unable to resolve target 'android-7' 解決方案：修改工程目錄下的default.properties文件里的內容target=android-7改成target=android-12(或者其他版本)就可以了，最好用txt
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類