iOS进阶-GCD信号量-dispatch_semaphore_t

信号量是计算机系统资源的计数器，为了解决多线程同步访问临界资源提出，通过预先设置信号总量，当有线程访问时，判断信号量减一是否为0，如果信号量减一不是0，线程就会执行其任务，发送信号量，信号量加1；如果为0，就进入等待，也就是线程阻塞，知道该访问资源的信号量减一不是0位置。

使用API ：

dispatch_semaphore_t有三个API函数：

dispatch_semaphore_create(long value); // 创建信号量
dispatch_semaphore_signal(dispatch_semaphore_t deem); // 发送信号量
dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout); // 等待信号量

dispatch_semaphore_create(long value);和GCD的group等用法一致，这个函数是创建一个dispatch_semaphore_t类型的信号量，并且创建的时候需要指定信号量的大小。
dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout); 等待信号量。如果信号量值为0，那么该函数就会一直等待，也就是不返回（相当于阻塞当前线程），直到该函数等待的信号量的值大于等于1，该函数会对信号量的值进行减1操作，然后返回。
dispatch_semaphore_signal(dispatch_semaphore_t deem); 发送信号量。该函数会对信号量的值进行加1操作。
通常等待信号量和发送信号量的函数是成对出现的。并发执行任务时候，在当前任务执行之前，用dispatch_semaphore_wait函数进行等待（阻塞），直到上一个任务执行完毕后且通过dispatch_semaphore_signal函数发送信号量（使信号量的值加1），dispatch_semaphore_wait函数收到信号量之后判断信号量的值大于等于1，会再对信号量的值减1，然后当前任务可以执行，执行完毕当前任务后，再通过dispatch_semaphore_signal函数发送信号量（使信号量的值加1），通知执行下一个任务......如此一来，通过信号量，就达到了并发队列中的任务同步执行的要求。

实例使用:

正常我们实现线程通过一般使用同步队列+（异步/同步）代码如下：

   dispatch_queue_t serialQueue = dispatch_queue_create("serail", DISPATCH_QUEUE_SERIAL);
    dispatch_async(serialQueue, ^{
        NSLog(@"任务1 current thread : %@",[NSThread currentThread]);
    });
    dispatch_async(serialQueue, ^{
        NSLog(@"任务2 current thread : %@",[NSThread currentThread]);
    });
    dispatch_async(serialQueue, ^{
        NSLog(@"任务3 current thread : %@",[NSThread currentThread]);
    });

image.png

GCD信号量方法实现同步任务执行，代码如下：

    // 因为队列是FIFO 保证：dispatch_semaphore_wait  任务进入队列的顺序是 任务1 、任务2 、任务3
    // 因为是异步执行，每个任务可能都会有线程 ，保证：每个任务执行完 执行 dispatch_semaphore_signal(_semaphore); 信号加一 下一个线程任务才能执行 执行顺序：  任务1 、任务2 、任务3
    
    dispatch_semaphore_t _semaphore = dispatch_semaphore_create(1);
    dispatch_queue_t globeQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    dispatch_semaphore_wait(_semaphore, DISPATCH_TIME_FOREVER);
    dispatch_async(globeQueue, ^{
        NSLog(@"任务1 current thread : %@",[NSThread currentThread]);
        dispatch_semaphore_signal(_semaphore);
    });

    dispatch_semaphore_wait(_semaphore, DISPATCH_TIME_FOREVER);
    dispatch_async(globeQueue, ^{
        NSLog(@"任务2 current thread : %@",[NSThread currentThread]);
        dispatch_semaphore_signal(_semaphore);

    });

    dispatch_semaphore_wait(_semaphore, DISPATCH_TIME_FOREVER);
    dispatch_async(globeQueue, ^{
        NSLog(@"任务3 current thread : %@",[NSThread currentThread]);
        dispatch_semaphore_signal(_semaphore);

image.png

网络请求中使用GCD信号量保证同步:

- (NSString *)getSSOToken {
    NSURLSession *session = [NSURLSession sharedSession];
    NSString *accessToken = [AlilangSDK sharedSDKInstance].accessToken;
    if (!accessToken) {
        return nil;
    }
    NSString *urlString = [NSString stringWithFormat:@"%@?appcode=%@&accesstoken=%@",SSO_TOKEN_URL,ALY_BUCAPPCODE,accessToken];
    NSURL *url = [NSURL URLWithString:urlString];
    dispatch_semaphore_t sem = dispatch_semaphore_create(0);
    NSURLSessionTask *task = [session dataTaskWithURL:url completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) {
        dispatch_async(dispatch_get_main_queue(), ^{
            self.SSOTokenDictionary = [NSJSONSerialization JSONObjectWithData:data options:NSJSONReadingAllowFragments error:nil];
            ALYLog(@"dict == %@",self.SSOTokenDictionary);
        });
        dispatch_semaphore_signal(sem);
    }];
    [task resume];
    
    dispatch_semaphore_wait(sem, DISPATCH_TIME_FOREVER);
    return [self.SSOTokenDictionary objectForKey:SSO_TOKEN];
}