信号量：就是一种可用来控制访问资源的数量的标识，设定了一个信号量，在线程访问之前，加上信号量的处理，则可告知系统按照我们指定的信号量数量来执行多个线程。
类似场景；排队时一次只能站五个人 ，剩余的等候进入队列 ，当前排一个人出列 ，剩余的人即可以有一个人加入队列。
信号量就是以这种方式排队执行
包含三个方法：
//创建信号量，参数：信号量的初值，如果小于0则会返回NULL
dispatch_semaphore_create（信号量值）//相当于排队时一次最大可容纳数 n
//等待降低信号量
dispatch_semaphore_wait（信号量，等待时间）占用信号量+1，剩余-1
//提高信号量
dispatch_semaphore_signal(信号量)释放信号量
创建一个最大信号量为 2
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); //此时信号量占用+1
NSLog(@"run task 1");
sleep(1);
NSLog(@"complete task 1");
dispatch_semaphore_signal(semaphore); 完成释放资源 -1
});<br>
//任务2
dispatch_async(quene, ^{
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);//此时信号量占用+1
NSLog(@"run task 2");
sleep(1);
NSLog(@"complete task 2");
dispatch_semaphore_signal(semaphore); 完成释放资源 -1
});
//当前资源剩余0 所以再有任务就需要任务一或者任务二完成释放资源方可。
//任务3 会等待任务一或者任务二完成时释放资源才可执行任务三
dispatch_async(quene, ^{
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
NSLog(@"run task 3");
sleep(1);
NSLog(@"complete task 3");
dispatch_semaphore_signal(semaphore);
});
执行顺序 run task 1
run task2
complete task 2
complete task 1
run task 3
complete task 3
设置信号量最大为1 ，可以实现各个队列顺序执行，1-2-3
//栅栏
/*
1,开启两个线程处理A和B
2,通过任务组执行A,B之后执行C
*/
dispatch_queue_t queue = dispatch_queue_create("dealWith", DISPATCH_QUEUE_CONCURRENT);
dispatch_group_t group = dispatch_group_create();
dispatch_group_async(group, queue, ^{
NSLog(@"A----%@",[NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
NSLog(@"B---%@",[NSThread currentThread]);
});
dispatch_group_notify(group, queue, ^{
NSLog(@"C---%@",[NSThread currentThread]);
});
需求： 有3个任务， 需要开启多条线程去执行。 有一个特殊任务0， 需要在1，2任务执行完后， 再执行3任务。
dispatch_queue_tqueue =dispatch_queue_create("test", DISPATCH_QUEUE_CONCURRENT);
dispatch_async(queue, ^{
NSLog(@"-------1----%@",[NSThreadcurrentThread]);
});
dispatch_async(queue, ^{
NSLog(@"-------2----%@",[NSThreadcurrentThread]);
});
//加入栅栏函数，执行任务0
dispatch_barrier_async(queue, ^{//不能使用全局队列
NSLog(@"barrier");
});
dispatch_async(queue, ^{
NSLog(@"-------3----%@",[NSThreadcurrentThread]);
});
网友评论