iOS-關於GCD信號量那些事兒

来源:https://www.cnblogs.com/wangkejia/archive/2020/03/31/12600352.html
-Advertisement-
Play Games

隨便說說 其實GCD大家都有接觸過，也不在解釋GCD是什麼，為什麼突然想說信號量問題，最近這幾次面試，當我問到面試者怎麼處理多個請求完成後的一系列操作時，有的說造一個臨時變數的做追加，其實這樣可以，也算是信號量的基本邏輯，有的說用線程做延時操作，怎麼延時，怎麼操作說的不清楚，有少部分會提到GCD信號 ...


隨便說說

其實GCD大家都有接觸過，也不在解釋GCD是什麼，為什麼突然想說信號量問題，最近這幾次面試，當我問到面試者怎麼處理多個請求完成後的一系列操作時，有的說造一個臨時變數的做追加，其實這樣可以，也算是信號量的基本邏輯，有的說用線程做延時操作，怎麼延時，怎麼操作說的不清楚，有少部分會提到GCD信號量，但是可能說不出來怎麼操作，通過信號量的增加與遞減，進行網路的併發請求，最後再做網路請求完成後的最終處理；其實實際上大家在做的時候，在網上一搜，基本都能找到；

GCD信號量的應用場景，一般是控制最大併發量，控制資源的同步訪問，如數據訪問，網路同步載入等。

需求1：多個網路請求完成後（無序）執行下一步 

先看下如果不用GCD線程組或信號量會怎麼執行

- (void)dispatchSyncSignal{
    NSString *urlString = @"http://www.baidu.com";
    NSURL *url = [NSURL URLWithString:urlString];
    NSURLRequest *request = [NSURLRequest requestWithURL:url];
    NSURLSession *session = [NSURLSession sharedSession];
    
    for (int i=0; i<5; i++) {
        NSURLSessionDataTask *task = [session dataTaskWithRequest:request completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"請求回調 %d---%d",i,i);
            
        }];
        
        [task resume];
    }
    NSLog(@"end");
}

運行後後臺列印輸出：

    

從上面兩次列印結果看出，end 先執行，由於網路請求的非同步回調，然後各個網路請求的回調順序是無序的。下麵針對需求進行操作；

使用GCD的線程組 dispatch_group_t

- (void)dispatchSyncSignal1{
    //創建線程組
    dispatch_group_t group = dispatch_group_create();
    NSString *urlString = @"http://www.baidu.com";
    NSURL *url = [NSURL URLWithString:urlString];
    NSURLRequest *request = [NSURLRequest requestWithURL:url];
    NSURLSession *session = [NSURLSession sharedSession];
    
    for (int i=0; i<5; i++) {
        dispatch_group_enter(group);
        NSURLSessionDataTask *task = [session dataTaskWithRequest:request completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"請求回調 %d---%d",i,i);
            dispatch_group_leave(group);
        }];
        
        [task resume];
    }
    
    dispatch_group_notify(group, dispatch_get_main_queue(), ^{
        NSLog(@"end");
    });
}

運行後後臺列印輸出：

   

從兩次列印輸出結果可以看出，end 是在所有網路請求之後才輸出，符合了我們的需求。然後說下用到的相關方法：

dispatch_group_create(); 創建一個dispatch_group_t；

dispatch_group_enter(); 每次網路請求前調用；

dispatch_group_leave(); 每次網路請求後調用；

dispatch_group_enter(); 和 dispatch_group_leave(); 必須配合使用，有幾次enter就要有幾次leave；

然後當所有dispatch_group_enter(); 的 block 都 dispatch_group_leave(); 後，會執行dispatch_group_notify的block。

使用GCD的信號量 semaphore_t

- (void)dispatchSyncSignal2{
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);

    NSString *urlString = @"http://www.baidu.com";
    NSURL *url = [NSURL URLWithString:urlString];
    NSURLRequest *request = [NSURLRequest requestWithURL:url];
    NSURLSession *session = [NSURLSession sharedSession];
    
   __block NSInteger count = 0;
    
    for (int i=0; i<5; i++) {
        
        NSURLSessionDataTask *task = [session dataTaskWithRequest:request completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"請求回調 %d---%d",i,i);
            count = count + 1;
            if (count == 5) {
                dispatch_semaphore_signal(semaphore);
                count = 0;
            }
        }];
        
        [task resume];
    }
    
    dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
    dispatch_async(dispatch_get_main_queue(), ^{
        NSLog(@"end");
    });
}

運行後後臺列印輸出：

  

從兩次列印輸出結果可以看出，end 也是在所有網路請求之後才輸出，也符合了我們的需求。然後說下用到的相關方法：

dispatch_semaphore 信號量如果計數為0，則等待。dispatch_semaphore_signal(semaphore)為計數+1，dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER)為設置等待時間，這裡設置的等待時間是永遠等待。對於以上代碼通俗一點講就是，開始為0，等待，等5個網路請求都完成了，計數+1，然後計數-1返回，程式繼續執行，count變數，記錄網路回調的次數，回調5次之後再發信號量，使後面程式繼續運行。

需求2：多個網路請求完成後（按順序）執行下一步 

如果按照需求1的方式，讓多個網路請求按順序執行完後，再進行下一步操作，那又應該怎麼執行，當然還可以用信號量來操作：

- (void)dispatchSignal3{
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
    NSString *urlString = @"http://www.baidu.com";
    NSURL *url = [NSURL URLWithString:urlString];
    NSURLRequest *request = [NSURLRequest requestWithURL:url];
    NSURLSession *session = [NSURLSession sharedSession];
    for (int i=0; i<5; i++) {
        NSURLSessionDataTask *task = [session dataTaskWithRequest:request completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
            NSLog(@"請求回調 %d---%d",i,i);
            dispatch_semaphore_signal(semaphore);
        }];
        [task resume];
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
    }

    dispatch_async(dispatch_get_main_queue(), ^{
        NSLog(@"end");
    });
}

運行後後臺列印輸出：

  

從兩次列印輸出結果可以看出，所有網路請求按順序依次執行，end 在所有請求完成後輸出，符合了我們的需求。

方法中每一次遍歷，都執行以下 dispatch_semaphore_wait()，這個時候線程會等待，阻塞當前線程，直到dispatch_semaphore_signal(sem)調用之後，再繼續下一次遍歷。

簡單說說 

信號量是用於多線程同步的，跟鎖不一樣的是，信號量不一定是鎖定某一個資源，而是流程上的概念，比如：有A、B兩個線程，B線程要等A線程完成某一任務以後再進行自己下麵的步驟，這個任務 並不一定是鎖定某一資源，其實還可以是進行一些計算或者數據處理之類；

下麵再通過做一個基於 NSObject 的生產者、消費者的 XKGradeRoom 工作間，看下信號量的用法，我們可以給生產間定一個最大生產量（這裡定2個），畢竟生產間也不能無限制的生產，通過生產者與消費者關係，合理的對生產間的產量進行把控，在產量達到最大產量時，就停止生產，等待消費者消費。

XKGradeRoom.h

#import <Foundation/Foundation.h>

/**
 生產消費工作間
 */
@interface XKGradeRoom : NSObject

/**
 生產
 */
- (void)xk_produce:(NSString *)sp;

/**
 消費

 @return NSString
 */
- (NSString*)xk_comsumer;
@end

XKGradeRoom.m

#import "XKGradeRoom.h"
@interface XKGradeRoom()
/**
 倉庫
 */
@property(strong,nonatomic) NSMutableArray* baseArray;

/**
 訪問倉庫（臨界區）的互斥訪問信號量
 */
@property(strong,nonatomic) dispatch_semaphore_t criticalSemaphore;

/**
 消費者-是否消費倉庫對象的標記
 */
@property(strong,nonatomic) dispatch_semaphore_t comsumerSemaphore;

/**
 生產者-是否生產對象的標記
 */
@property(strong,nonatomic) dispatch_semaphore_t productSemaphore;

/**
 倉庫裝載最大量
 */
@property(nonatomic,assign) int maxProductCount;

@end
@implementation XKGradeRoom
- (instancetype)init{
    self = [super init];
    if (self) {
        [self setup];
    }
    return self;
}
- (void)setup{
    _maxProductCount = 2;
    self.baseArray = [NSMutableArray array];
    self.productSemaphore = dispatch_semaphore_create(_maxProductCount);
    self.comsumerSemaphore = dispatch_semaphore_create(0);
    //初始化臨界區互斥訪問信號量,用信號量實現互斥,特殊初始值為1.
    //控制同一時刻只有一個線程對象在訪問倉庫
    self.criticalSemaphore = dispatch_semaphore_create(1);
}


/**
 生產
 */
-(void)xk_produce:(NSString *)sp{
   //先獲取訪問倉庫的信號量
    long baseCount = dispatch_semaphore_wait(self.criticalSemaphore,  5 * NSEC_PER_SEC);
    if(baseCount != 0){
        NSLog(@"倉庫有人正在使用，生產者處於等待");
    }else{
        //再判斷 倉庫是否還有可放物品的空間
        long maxSpaceCount = dispatch_semaphore_wait(self.productSemaphore, 5 * NSEC_PER_SEC);
        
        if(maxSpaceCount != 0){
            NSLog(@"倉庫%d個空間已經使用完，生產者處於等待：倉庫容量:%lu",_maxProductCount,[self.baseArray count]);
            //生產完了釋放臨界區的訪問鎖
            dispatch_semaphore_signal(self.criticalSemaphore);
        }else{
            
            [self.baseArray addObject:sp];
             NSLog(@"新生產一個,倉庫目前有：%lu",[self.baseArray count]);
            dispatch_semaphore_signal(self.criticalSemaphore);
            dispatch_semaphore_signal(self.comsumerSemaphore);
          
        }
    }
}

/**
 消費
 
 @return NSString
 */
-(NSString*)xk_comsumer{
    NSString* e = nil;
    long baseCount = dispatch_semaphore_wait(self.criticalSemaphore, 5 * NSEC_PER_SEC);        //先獲取訪問倉庫的信號量
    if(baseCount != 0){
        NSLog(@"倉庫有人正在使用，消費者處於等待");
    }else{
        //再判斷 倉庫是否還有可取，如果有物品，則取一個出來，否則t等待
        long avableCount = dispatch_semaphore_wait(self.comsumerSemaphore, 5 * NSEC_PER_SEC);
        if(avableCount != 0){
            NSLog(@"空倉，消費者處於等待");
            //生產完了釋放臨界區的訪問鎖
            dispatch_semaphore_signal(self.criticalSemaphore);
        }else{
            e = [self.baseArray objectAtIndex:[self.baseArray count] -1];
            [self.baseArray removeLastObject];
            NSLog(@"消費了:%@ 倉庫還有%lu:",e,[self.baseArray count]);
            //生產完了釋放臨界區的訪問鎖
            dispatch_semaphore_signal(self.criticalSemaphore);
            //將倉庫中的可放置的數量 +1
            dispatch_semaphore_signal(self.productSemaphore);
        }
    }
    return e;
}
@end

下麵測試下這個工作間

XKGradeRoom * gradeRoom = [XKGradeRoom new];
    
    //創建一個myDispatchQueue，主要是用於防止資源的競爭，一個線程處使用完資源，然後另外一個才能繼續使用
    dispatch_queue_t myDispatchQueue =  dispatch_queue_create("com.example.gcd,myDispatchQueue", NULL);
    dispatch_async(myDispatchQueue, ^{
        [gradeRoom xk_produce:@"Queue1"];
        NSLog(@"Queue1-執行完畢");
    });
    dispatch_async(myDispatchQueue, ^{
        [gradeRoom xk_comsumer];
        NSLog(@"Queue2-執行完畢");
    });
    dispatch_async(myDispatchQueue, ^{
        [gradeRoom xk_comsumer];
        NSLog(@"Queue3-執行完畢");
    });
    dispatch_async(myDispatchQueue, ^{
        [gradeRoom xk_produce:@"Queue4"];
        NSLog(@"Queue4-執行完畢");
    });
    dispatch_async(myDispatchQueue, ^{
        [gradeRoom xk_produce:@"Queue5"];
        NSLog(@"Queue5-執行完畢");
    });
    dispatch_async(myDispatchQueue, ^{
        [gradeRoom xk_produce:@"Queue6"];
        NSLog(@"Queue6-執行完畢");
    });
    
    dispatch_async(myDispatchQueue, ^{
        [gradeRoom xk_comsumer];
        [gradeRoom xk_comsumer];
        [gradeRoom xk_comsumer];
        [gradeRoom xk_comsumer];
        NSLog(@"Queue7-執行完畢");
    });

列印結果：

 


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

-Advertisement-
Play Games
更多相關文章
  • mysql按日期做曲線圖統計，如果當天沒有數據則日期不全、補全日期
    侵刪。不足之處請諒解。 工作中遇到的問題： 不會就百度，多百度幾次總會有自己需要的。比如這個曲線統計，我也是借用了博客里的各位大大，然後按照自己項目需求做的，頁面給前端懟數據去就行，下麵是步驟 1，用戶統計曲線圖，如果其中某一天沒有數據，曲線圖的日期鏈接不起來，如圖： 我的解決方法：靠百度。首先生成 ...
  • MySQL 外鍵關聯策略
    eg.一個用戶可有擁有多個訂單，一個訂單隻能屬於一個用戶，一對多，在tb_order中使用外鍵user_id關聯tb_user的id。 當刪除、更新tb_user中的主鍵時，與之關聯的tb_order要受到影響，比如 #tb_user中的一條記錄 1 chy abcd #tb_order中一條記錄， ...
  • 乾貨來了！阿裡發佈近300頁Flink實戰電子書
    近300頁實用乾貨總結，幫你解決 Flink 實戰應用難題！《Apache Flink電子書合輯》收錄來自bilibili、美團點評、小米、OPPO、快手、Lyft、Netflix等一線大廠實時計算平臺及實時數倉實踐案例，更有來自阿裡巴巴及Apache Flink核心貢獻者們一線實戰經驗總結。 頁面 ...
  • 如何使用H5的video實現全屏時橫屏播放，手勢上下滑動調節音量，左右滑動快進和後退
    現在的大部分播放器都實現了手勢上下滑動調節音量，左右滑動快進和後退，在大部分app中幾乎是主流配置了。如果app中提供了視頻功能，而沒有這些基本的功能，用戶體驗就很差。由於平常使用5+ Runtime，配合H5的Video標簽實現起來也不麻煩。主要是為了測試hls.js，播放m3u8地址就做了一個d ...
  • Android LinearLayout線性佈局詳解
    為了更好地管理Android應用的用戶界面里的各組件，Android提供了佈局管理器。通過使用佈局管理器，Android應用圖形用戶界面具有良好的平臺無關性。推薦使用佈局管理器來管理組件的分佈、大小，而不是直接設置組件的位置和大小。可以使用佈局管理器嵌套佈局管理器，即也可作為一個UI組件來使用。 L ...
  • Android 智能手機開發概述
    Android SDK Android SDK 提供了在 Window/Linux/Mac 等平臺上開發 Android 應用程式的相應的開發組件。它含有在 Android 平臺上開發應用程式的工具集。 總體架構 Android 最底層基於 Linux 2.6 內核實現，負責硬體驅動、網路管理、電源 ...
  • Glide的使用解析
    Glide基本用法 Glide.with(this).load(url).into(imageView); 1.with() 得到RequestManager，調用Glide.with()方法用於創建一個載入圖片的實例。 如果傳入的是ApplicationContext，那麼只有當應用程式被殺掉的時 ...
  • Android 獲取開發&測試 SHA1值
    以前都是直接安裝一個開發者助手獲取的，但是呢，開發者助手也有bug啊，應用寶下載安裝，在我的紅米手機上發現打不開，於是我又去酷安網下載了一個，可以打開了，但是有問題，沒法獲取到完整的root許可權，檢測不准確，當前應用根本看不到東西，於是只能另想辦法了，老套路就是百度，然後照著搞，發現很多都是直接 k ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類