美文网首页
GCD之dispatch_semaphore

GCD之dispatch_semaphore

作者: iOSLee | 来源:发表于2017-12-06 10:53 被阅读0次

介绍

信号量是一个整形值并且具有一个初始计数值,并且支持两个操作:信号通知和等待。当一个信号量被信号通知,其计数会被增加。当一个线程在一个信号量上等待时,线程会被阻塞(如果有必要的话),直至计数器大于零,然后线程会减少这个计数。

在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,输出结果可自行调试

相关文章

网友评论

      本文标题:GCD之dispatch_semaphore

      本文链接:https://www.haomeiwen.com/subject/fqrkixtx.html