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
  • Dapr Outbox 執行流程
    Dapr Outbox 是1.12中的功能。 本文只介紹Dapr Outbox 執行流程，Dapr Outbox基本用法請閱讀官方文檔 。本文中appID=order-processor，topic=orders 本文前提知識：熟悉Dapr狀態管理、Dapr發佈訂閱和Outbox 模式。 Outbo ...
  • Advanced .Net Debugging 7：托管堆與垃圾收集
    引言 在前幾章我們深度講解了單元測試和集成測試的基礎知識，這一章我們來講解一下代碼覆蓋率,代碼覆蓋率是單元測試運行的度量值,覆蓋率通常以百分比表示，用於衡量代碼被測試覆蓋的程度，幫助開發人員評估測試用例的質量和代碼的健壯性。常見的覆蓋率包括語句覆蓋率（Line Coverage）、分支覆蓋率（Bra ...
  • C#S7.NET實現西門子PLCDB塊數據採集的完整步驟
    前言 本文介紹瞭如何使用S7.NET庫實現對西門子PLC DB塊數據的讀寫，記錄了使用電腦模擬，模擬PLC，自至完成測試的詳細流程，並重點介紹了在這個過程中的易錯點，供參考。 用到的軟體： 1.Windows環境下鏈路層網路訪問的行業標準工具（WinPcap_4_1_3.exe）下載鏈接：http ...
  • WPF控制項：密碼框綁定MVVM
    從依賴倒置原則（Dependency Inversion Principle, DIP）到控制反轉（Inversion of Control, IoC）再到依賴註入（Dependency Injection, DI）的演進過程，我們可以理解為一種逐步抽象和解耦的設計思想。這種思想在C#等面向對象的編 ...
  • Python中的私有屬性與私有方法
    關於Python中的私有屬性和私有方法 Python對於類的成員沒有嚴格的訪問控制限制，這與其他面相對對象語言有區別。關於私有屬性和私有方法，有如下要點： 1、通常我們約定，兩個下劃線開頭的屬性是私有的（private）。其他為公共的（public）； 2、類內部可以訪問私有屬性（方法）； 3、類外 ...
  • C++ 訪問說明符詳解：封裝數據，控制訪問，提升安全性
    C++ 訪問說明符 訪問說明符是 C++ 中控制類成員（屬性和方法）可訪問性的關鍵字。它們用於封裝類數據並保護其免受意外修改或濫用。 三種訪問說明符： public：允許從類外部的任何地方訪問成員。 private：僅允許在類內部訪問成員。 protected：允許在類內部及其派生類中訪問成員。 示 ...
  • static_cast與dynamic_cast到底是什麼？
    寫這個隨筆說一下C++的static_cast和dynamic_cast用在子類與父類的指針轉換時的一些事宜。首先，【static_cast，dynamic_cast】【父類指針，子類指針】，兩兩一組，共有4種組合：用 static_cast 父類轉子類、用 static_cast 子類轉父類、使用 ...
  • C語言數據結構：雙向鏈表的增刪操作
    /******************************************************************************************************** * * * 設計雙向鏈表的介面 * * * * Copyright (c) 2023-2 ...
  • @ComponentScan註解的實現，Spring掃描包的過程
    相信接觸過spring做開發的小伙伴們一定使用過@ComponentScan註解 @ComponentScan("com.wangm.lifecycle") public class AppConfig { } @ComponentScan指定basePackage，將包下的類按照一定規則註冊成Be ...
  • opensips開啟python支持
    操作系統 ：CentOS 7.6_x64 opensips版本： 2.4.9 python版本：2.7.5 python作為腳本語言，使用起來很方便，查了下opensips的文檔，支持使用python腳本寫邏輯代碼。今天整理下CentOS7環境下opensips2.4.9的python模塊筆記及使用 ...
所有分類