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
  • C#自增運算符詳解：++i與i++的區別及應用場景
    概述：在C#中，++i和i++都是自增運算符，其中++i先增加值再返回，而i++先返回值再增加。應用場景根據需求選擇，首碼適合先增後用，尾碼適合先用後增。詳細示例提供清晰的代碼演示這兩者的操作時機和實際應用。 在C#中，++i 和 i++ 都是自增運算符，但它們在操作上有細微的差異，主要體現在操作的 ...
  • Taurus.MVC 性能壓力測試（ap 壓測 和 linux 下wrk 壓測）：.NET 版本
    上次發佈了：Taurus.MVC 性能壓力測試（ap 壓測 和 linux 下wrk 壓測）：.NET Core 版本，今天計劃準備壓測一下 .NET 版本，來測試並記錄一下 Taurus.MVC 框架在 .NET 版本的性能，以便後續持續優化改進。 為了方便對比，本文章的電腦環境和測試思路，儘量和... ...
  • 一文讀懂.NET WebAPI中FromRoute、FromQuery、FromBody的關鍵角色與用法
    .NET WebAPI作為一種構建RESTful服務的強大工具，為開發者提供了便捷的方式來定義、處理HTTP請求並返迴響應。在設計API介面時，正確地接收和解析客戶端發送的數據至關重要。.NET WebAPI提供了一系列特性，如[FromRoute]、[FromQuery]和[FromBody]，用 ...
  • WPF/C#實現圖像濾鏡優化方案：打造炫目視覺體驗！
    原因：我之所以想做這個項目，是因為在之前查找關於C#/WPF相關資料時，我發現講解圖像濾鏡的資源非常稀缺。此外，我註意到許多現有的開源庫主要基於CPU進行圖像渲染。這種方式在處理大量圖像時，會導致CPU的渲染負擔過重。因此，我將在下文中介紹如何通過GPU渲染來有效實現圖像的各種濾鏡效果。 生成的效果 ...
  • Bogus 實戰：使用 Bogus 和 EFCore 生成模擬數據和種子數據【完整教程】
    引言 上一章我們介紹了在xUnit單元測試中用xUnit.DependencyInject來使用依賴註入，上一章我們的Sample.Repository倉儲層有一個批量註入的介面沒有做單元測試，今天用這個示例來演示一下如何用Bogus創建模擬數據 ，和 EFCore 的種子數據生成 Bogus 的優 ...
  • WPF隨筆收錄-實時繪製心率曲線
    一、前言 在自己的項目中，涉及到實時心率曲線的繪製，項目上的曲線繪製，一般很難找到能直接用的第三方庫，而且有些還是定製化的功能，所以還是自己繪製比較方便。很多人一聽到自己畫就害怕，感覺很難，今天就分享一個完整的實時心率數據繪製心率曲線圖的例子；之前的博客也分享給DrawingVisual繪製曲線的方 ...
  • wpf程式修改啟動入口註意事項
    如果你在自定義的 Main 方法中直接使用 App 類並啟動應用程式，但發現 App.xaml 中定義的資源沒有被正確載入，那麼問題可能在於如何正確配置 App.xaml 與你的 App 類的交互。 確保 App.xaml 文件中的 x:Class 屬性正確指向你的 App 類。這樣，當你創建 Ap ...
  • 記一次 .NET某爐膛鍋爐檢測系統 崩潰分析
    一：背景 1. 講故事 上個月有個朋友在微信上找到我，說他們的軟體在客戶那邊隔幾天就要崩潰一次，一直都沒有找到原因，讓我幫忙看下怎麼回事，確實工控類的軟體環境複雜難搞，朋友手上有一個崩潰的dump，剛好丟給我來分析一下。 二：WinDbg分析 1. 程式為什麼會崩潰 windbg 有一個厲害之處在於 ...
  • 一個.NET內置依賴註入的小型強化版
    前言 .NET生態中有許多依賴註入容器。在大多數情況下，微軟提供的內置容器在易用性和性能方面都非常優秀。外加ASP.NET Core預設使用內置容器，使用很方便。 但是筆者在使用中一直有一個頭疼的問題：服務工廠無法提供請求的服務類型相關的信息。這在一般情況下並沒有影響，但是內置容器支持註冊開放泛型服 ...
  • WPF隨筆收錄-DataGrid固定右側列
    一、前言 在項目開發過程中，DataGrid是經常使用到的一個數據展示控制項，而通常表格的最後一列是作為操作列存在，比如會有編輯、刪除等功能按鈕。但WPF的原始DataGrid中，預設只支持固定左側列，這跟大家習慣性操作列放最後不符，今天就來介紹一種簡單的方式實現固定右側列。（這裡的實現方式參考的大佬 ...
所有分類