IOS信号量(PV操作)

GCD中类似的API也可以实现大部分相同的操作：

 // 创建队列组
    dispatch_group_t group = dispatch_group_create();
    // 创建并发队列
    dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
  [SVProgressHUD show];
   //第一个任务
    dispatch_group_enter(group); //相当于wait
    dispatch_group_async(group, queue, ^{
         dispatch_group_leave(group); // 相当于signal
    });
//第二个任务
  dispatch_group_enter(group);
    dispatch_group_async(group, queue, ^{
         dispatch_group_leave(group);
    });
  //全部完成后最后在这个方法里处理
 dispatch_group_notify(group, queue, ^{
        dispatch_async(dispatch_get_main_queue(), ^{
             [SVProgressHUD dismiss];
        });
    });

一、信号量的简单介绍：

1.信号量：

信号量(Semaphore)，有时被称为信号灯，是在多线程环境下使用的一种设施，是可以用来保证两个或多个关键代码段不被并发调用。在进入一个关键代码段之前，线程必须获取一个信号量；一旦该关键代码段完成了，那么该线程必须释放信号量。其它想进入该关键代码段的线程必须等待直到第一个线程释放信号量。为了完成这个过程，需要创建一个信号量VI，然后将Acquire Semaphore VI以及Release Semaphore VI分别放置在每个关键代码段的首末端。确认这些信号量VI引用的是初始创建的信号量。

2.特性：

抽象的来讲，信号量的特性如下：信号量是一个非负整数（车位数），所有通过它的线程/进程（车辆）都会将该整数减一（通过它当然是为了使用资源），当该整数值为零时，所有试图通过它的线程都将处于等待状态。在信号量上我们定义两种操作： Wait（等待）和 Release（释放）。当一个线程调用Wait操作时，它要么得到资源然后将信号量减一，要么一直等下去（指放入阻塞队列），直到信号量大于等于一时。Release（释放）实际上是在信号量上执行加操作，对应于车辆离开停车场，该操作之所以叫做“释放”是因为释放了由信号量守护的资源。

3.描述：

以一个停车场的运作为例。简单起见，假设停车场只有三个车位，一开始三个车位都是空的。这时如果同时来了五辆车，看门人允许其中三辆直接进入，然后放下车拦，剩下的车则必须在入口等待，此后来的车也都不得不在入口处等待。这时，有一辆车离开停车场，看门人得知后，打开车拦，放入外面的一辆进去，如果又离开两辆，则又可以放入两辆，如此往复。
在这个停车场系统中，车位是公共资源，每辆车好比一个线程，看门人起的就是信号量的作用。

4.发展史：

1965年，荷兰学者Edsger Dijkstra提出的信号量(Semaphores)机制是一种卓有成效的进程同步工具，在长期广泛的应用中，信号量机制得到了极大的发展，它从整型信号量经记录型信号量，进而发展成为“信号量集机制”，现在信号量机制已经被广泛的应用到单处理机和多处理机系统以及计算机网络中。

5.在IOS系统GCD的semaphore.h头文件中提供三个方法进行PV操作

在IOS系统GCD的semaphore.h头文件中提供三个方法进行PV操作
// 这value是初始化多少个信号量
1.dispatch_semaphore_create(long value); 
// 这个方法是P操作对信号量减一，dsema这个参数表示对哪个信号量进行减一，如果该信号量为0则等待，timeout这个参数则是传入等待的时长。
2.dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout); 
// 这个方法是V操作对信号量加一，dsema这个参数表示对哪个信号量进行加一
3.dispatch_semaphore_signal(dispatch_semaphore_t dsema);

5.常见的信号量的应用场景

1.加锁(互斥)
2.异步返回
3.控制线程并发数

二、下面是最简单的例子，利用信号量或同步锁对多线程操作iphoneNumber变量进行互斥。(第一种情况加锁)

//
//  ViewController.m
//  semaphoreTest2
//
//  Created by huangxianchao on 17/05/2017.
//  Copyright © 2017 黄先超. All rights reserved.
//

#import "ViewController.h"

@interface ViewController ()

/// iphone的数量
@property (nonatomic,assign) int iphoneNumber;
/// 互斥用的信号量
@property (nonatomic,strong) dispatch_semaphore_t semaphore;

@end

@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    
    self.iphoneNumber = 1000;
    // 初始化1个信号量
    self.semaphore = dispatch_semaphore_create(1);
    
    /// 通过信号量进行互斥，开启三个窗口(线程)同时卖iphone
    NSThread *thread1 = [[NSThread alloc] initWithTarget:self selector:@selector(sellIphone) object:nil];
    thread1.name = @"窗口1";
    NSThread *thread2 = [[NSThread alloc] initWithTarget:self selector:@selector(sellIphone) object:nil];
    thread2.name = @"窗口2";
    NSThread *thread3 = [[NSThread alloc] initWithTarget:self selector:@selector(sellIphone) object:nil];
    thread3.name = @"窗口3";
    
    /// 通过同步锁进行互斥，开启三个窗口(线程)同时卖iphone
//    NSThread *thread1 = [[NSThread alloc] initWithTarget:self selector:@selector(sellIphoneWithSynchronization) object:nil];
//    thread1.name = @"窗口1";
//    NSThread *thread2 = [[NSThread alloc] initWithTarget:self selector:@selector(sellIphoneWithSynchronization) object:nil];
//    thread2.name = @"窗口2";
//    NSThread *thread3 = [[NSThread alloc] initWithTarget:self selector:@selector(sellIphoneWithSynchronization) object:nil];
//    thread3.name = @"窗口3";
    [thread1 start];
    [thread2 start];
    [thread3 start];
}

/// 通过信号量达到互斥
- (void)sellIphone
{
    while (1) {
        // P操作对信号量进行减一，然后信号量变0，限制其他窗口(线程)进入
        dispatch_semaphore_wait(self.semaphore, DISPATCH_TIME_FOREVER);
        
        if (self.iphoneNumber > 0) // 检查还有没iphone可卖
        {
            NSLog(@"卖出iphone剩下%d台iphone",--self.iphoneNumber);
            
        }
        else
        {
            NSLog(@"iphone没有库存了");
            return;
        }
        
        // V操作对信号量进行加一，然后信号量为1，其他窗口(线程)就能进入了
        dispatch_semaphore_signal(self.semaphore);
    }
}

/// 通过同步锁进行互斥，通过同步锁会比通过信号量控制的方式多进入该临界代码（线程数量-1）次
- (void)sellIphoneWithSynchronization
{
    while (1) {
        
        @synchronized (self) {
            if (self.iphoneNumber > 0) // 检查还有没iphone可卖
            {
                NSLog(@"%@卖出iphone剩下%d台iphone",[NSThread currentThread].name,--self.iphoneNumber);
            }
            else
            {
                NSLog(@"iphone没有库存了");
                return;
            }

        }
    }
}


@end

注意：如果不理解可以注释信号量代码或者同步锁代码仔细观察iphoneNumber值的变化

三、异步任务同步返回

(Status *)getNetworkStatus {
__block Status *status = nil;
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
[self getResultWithCompletionHandler:^(Status *statusModel, BOOL isSuccess) {
//
if(isSuccess)
{
status = statusModel;
}
dispatch_semaphore_signal(semaphore);

}];

dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);

return status;
}

四、控制同一个信号量(临界资源)下的相关线程在并发队列中最大的并发数，如果想控制并发数是1可以使用串行队列，不需要信号量去限制（第三种情况控制线程中任务的并发数）

这第一个demo可能比较直观

   //这里的value控制基于semaphore这个信号量的相关线程最多几个线程并发运行
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(3);
    dispatch_queue_t quene = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    for (int i = 0; i < 10000; i++) {
        //线程1
        dispatch_async(quene, ^{
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
                NSLog(@"%@",[NSString stringWithFormat:@"thread1 start%d",i]);
            sleep(2.0);
            NSLog(@"%@",[NSString stringWithFormat:@"thread1 finish%d",i]);
            dispatch_semaphore_signal(semaphore);
        });

    }

下面是第二个demo（第三种情况控制线程中任务的并发数）

//
//  ViewController.m
//  samephoreTest3
//
//  Created by huangxianchao on 17/05/2017.
//  Copyright © 2017 黄先超. All rights reserved.
//

#import "ViewController.h"

@interface ViewController ()

@end

@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    
    //这里的value控制基于semaphore这个信号量的相关线程最多几个线程并发运行
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(2);
    dispatch_queue_t quene = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    //线程1
    dispatch_async(quene, ^{
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        NSLog(@"thread1 start");
        dispatch_semaphore_signal(semaphore);
        NSLog(@"thread1 finish");
        
    });
    //线程2
    dispatch_async(quene, ^{
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        NSLog(@"thread2 start");
        dispatch_semaphore_signal(semaphore);
        NSLog(@"thread2 finish");
    });
    //线程3
    dispatch_async(quene, ^{
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        NSLog(@"thread3 start");
        dispatch_semaphore_signal(semaphore);
        NSLog(@"thread3 finish");
    });
}

@end

下面是两个现实生活的例子

一、这是关于公交车上司机和售票员的配合问题。（第一种情况）加锁(互斥)）

1.司机需要等待售票员关门后才能开车
2.售票员需要等待司机停车后才能开门

// 司机是否停车的信号量，
    dispatch_semaphore_t semaphoreStopBused = dispatch_semaphore_create(1);
    // 售票员是否关门的信号量
    dispatch_semaphore_t semaphoreCloseDoored = dispatch_semaphore_create(0);
    // 拿到全局队列
    dispatch_queue_t quene = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    // 司机的相关操作
    dispatch_async(quene, ^{
        while (1) {
            // 司机等待售票员关门,DISPATCH_TIME_FOREVER表示这个信号量如果是0就一直等待这个信号量
            dispatch_semaphore_wait(semaphoreCloseDoored, DISPATCH_TIME_FOREVER);
            NSLog(@"司机开车");
            NSLog(@"司机停车");
            // 司机已关门，停车的信号量加一
            dispatch_semaphore_signal(semaphoreStopBused);
        }
    });
    
    // 售票员的相关操作
    dispatch_async(quene, ^{
        while (1) {
            // 售票员等待司机停车
            dispatch_semaphore_wait(semaphoreStopBused, DISPATCH_TIME_FOREVER);
            NSLog(@"售票员开门");
            NSLog(@"售票员关门");
            // 售票员已经关门，关门的信号量加一
             dispatch_semaphore_signal(semaphoreCloseDoored);
            
        }
    });

注意：
1.semaphoreStopBused和semaphoreCloseDoored信号量只能同时有一个是1，这值表示当前是停车了还是关门了，会触发相关的流程
2.让semaphoreCloseDoored为1，semaphoreStopBused为0试试，观察最开始的流程走的顺序有什么不同

二、生产和销售的问题（第一种情况加锁(互斥)）

/*
     生产和销售的线程同时操纵iphoneNumber变量为了保证数据的正确性，并且生产到5台iphone就不再生产了。
    
     */
    
    // iphone数量
    __block int iphoneNumber = 0;
    // 生产和销售的互斥
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
    
    // 拿到全局队列
    dispatch_queue_t quene = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    // 生产iphone
    dispatch_async(quene, ^{
        while (1) {
            // 生产和销售的互斥,等待信号量
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            if (iphoneNumber < 5) {
                NSLog(@"生产iphone,目前有%d台",++iphoneNumber);
            }
            dispatch_semaphore_signal(semaphore);
            
        }
    });
    
    // 销售iphone
    dispatch_async(quene, ^{
        while (1) {
            // 生产和销售的互斥,等待信号量
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            if (iphoneNumber > 0) {
                NSLog(@"卖掉一台iphone,目前有%d台",--iphoneNumber);
            }
            dispatch_semaphore_signal(semaphore);
            
        }
    });

22702FAC-1779-4C57-86A1-73C7E74A1121.png

上面图的结果是正确的，生产和销售后的数据都能对的上。

如果把代码更改为下面的情况，就是不用信号量去做互斥的话，看下图生成的错误结果图

/*
     生产和销售的互斥保证得到的数据是正确的，并且生产到5台iphone就不再生产了
     */
    
    // iphone数量
    __block int iphoneNumber = 0;
    // 生产和销售的互斥
//    dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
    
    // 拿到全局队列
    dispatch_queue_t quene = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    // 生产iphone
    dispatch_async(quene, ^{
        while (1) {
            // 生产和销售的互斥,等待信号量
//            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            if (iphoneNumber < 5) {
                NSLog(@"生产iphone,目前有%d台",++iphoneNumber);
            }
//            dispatch_semaphore_signal(semaphore);
            
        }
    });
    
    // 销售iphone
    dispatch_async(quene, ^{
        while (1) {
            // 生产和销售的互斥,等待信号量
//            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            if (iphoneNumber > 0) {
                NSLog(@"卖掉一台iphone,目前有%d台",--iphoneNumber);
            }
//            dispatch_semaphore_signal(semaphore);
            
        }
    });

看下图生成的错误结果图

图片.png

上图的结果有两处错误

1.连续生产两次iphone后产品的数量都是5。
2.连续卖掉两次iphone后产品的数量都是4。

注意：dispatch_semaphore_dispose奔溃就是因为信号量堵塞和释放没算好

参考资料：
http://baike.baidu.com/link?url=xfbl90QNrVjVE1oqELnAEYYvwI86XG_FLz-QEp9y4kn3icGzRXDwiPi4ICZ2FNhff8ho8MghcQyA0OaBRZKGMDKfUAsipmyooTWNyfdngjYkQ_krzsD_7KaSH_4PFv7y

最后编辑于：2018.08.27 16:09:46

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 204,293评论 6赞 478
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,604评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,958评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,729评论 1赞 277
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,719评论 5赞 366
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,630评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 38,000评论 3赞 397
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,665评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,909评论 1赞 299
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,646评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,726评论 1赞 330
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,400评论 4赞 321
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,986评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,959评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,197评论 1赞 260
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 44,996评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,481评论 2赞 342