介绍
信号量是一个整形值并且具有一个初始计数值,并且支持两个操作:信号通知和等待。当一个信号量被信号通知,其计数会被增加。当一个线程在一个信号量上等待时,线程会被阻塞(如果有必要的话),直至计数器大于零,然后线程会减少这个计数。
在GCD中有三个函数是semaphore的操作,分别是:
dispatch_semaphore_create 创建一个semaphore
dispatch_semaphore_signal 发送一个信号
dispatch_semaphore_wait 等待信号
dispatch_semaphore_create
1、作用:创建具有初始值的计数信号量
2、使用:
//需要多个线程进行协调工作的时候,初始值传0,用于阻塞当前线程,比如两个异步操作串行执行
dispatch_semaphore_create(0);
//管理一个有限的线程池,初始值n > 0,线程池的大小与初始值相等
dispatch_semaphore_create(n);
dispatch_semaphore_wait
1、作用:等待(减少)一个信号
2、使用:
//信号量semaphore计数减1。如果结果值小于零,这个函数会阻塞当前线程等待一个信号。注意:semaphore不能为NULL
//dispatch_time_t 可以自定义也可以使用系统内置的连个宏(DISPATCH_TIME_NOW/DISPATCH_TIME_FOREVER)
dispatch_semaphore_wait(semaphore, dispatch_time_t);
dispatch_semaphore_signal
1、作用:发送(增加)一个信号
2、使用:
//信号量semaphore计数加1,如果在此之前semaphore已经小于0,在返回之前唤醒了一个等待线程,注意:semaphore不能为NULL
dispatch_semaphore_signal(semaphore);
案例
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
dispatch_queue_t queue = dispatch_queue_create("queue", DISPATCH_QUEUE_CONCURRENT);
NSLog(@"开始1");
dispatch_async(queue, ^{
NSLog(@"执行1");
dispatch_semaphore_signal(semaphore);
NSLog(@"释放1");
});
NSLog(@"等待1");
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
NSLog(@"开始2");
dispatch_async(queue, ^{
NSLog(@"执行2");
dispatch_semaphore_signal(semaphore);
NSLog(@"释放2");
});
NSLog(@"等待2");
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
NSLog(@"开始3");
dispatch_async(queue, ^{
NSLog(@"执行3");
dispatch_semaphore_signal(semaphore);
NSLog(@"释放3");
});
NSLog(@"等待3");
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
NSLog(@"结束");
例子中创建了一个初始值为0的信号量和一个并行队列, 采用异步执行,每个执行都有:开始、等待、执行、释放四步,本例中上一个的释放与下一个的开始是并行执行的,输出内容为:
也可以将本例中初始信号量的值修改为大于0,输出结果可自行调试