GCD线程同步的研究
在GCD中关于线程同步的问题，有很多中实现方式：Group函数，barrier函数，信号量等；这里只是简单研究一下关于GCD的用法
Group
group函数的作用：在追加到dispatch_queue中的多个处理，全部结束后，想要执行结束的处理
- (void)groupTest1 {
//创建组
dispatch_group_t group =dispatch_group_create();
//获取全局队列
dispatch_queue_tqueue =dispatch_get_global_queue(0,0);
//调度组的异步请求
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:3];
NSLog(@"下载第一张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:2];
NSLog(@"下载第二张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:4];
NSLog(@"下载第三张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:1];
NSLog(@"下载第四张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:6];
NSLog(@"下载第五张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:5];
NSLog(@"下载第六张图片");
});
// notify通知当所有异步请求完成时 调用该函数
dispatch_group_notify(group, queue, ^{
NSLog(@"刷新UI");
});
}
打印的结果
2017-06-23 02:16:08.043 GCD的研究[4203:300438]下载第四张图片
2017-06-23 02:16:09.046 GCD的研究[4203:300450]下载第二张图片
2017-06-23 02:16:10.046 GCD的研究[4203:300451]下载第一张图片
2017-06-23 02:16:11.043 GCD的研究[4203:300436]下载第三张图片
2017-06-23 02:16:12.043 GCD的研究[4203:300457]下载第六张图片
2017-06-23 02:16:13.043 GCD的研究[4203:300435]下载第五张图片
2017-06-23 02:16:13.044 GCD的研究[4203:300435]刷新UI
去掉sleep之后的打印结果，没次打印的结果都不相同 但是刷新UI一直在最后才打印
2017-06-23 02:17:34.132 GCD的研究[4220:301522]下载第二张图片
2017-06-23 02:17:34.132 GCD的研究[4220:301506]下载第三张图片
2017-06-23 02:17:34.132 GCD的研究[4220:301509]下载第四张图片
2017-06-23 02:17:34.132 GCD的研究[4220:301529]下载第五张图片
2017-06-23 02:17:34.133 GCD的研究[4220:301530]下载第六张图片
2017-06-23 02:17:34.132 GCD的研究[4220:301507]下载第一张图片
2017-06-23 02:17:34.137 GCD的研究[4220:301530]刷新UI
两者比较，在该异步线程中，任务是同时进行，notify通知在group任务完成以后，才会调用
wait函数
- (void)groupTest3 {
//创建组
dispatch_group_tgroup =dispatch_group_create();
//获取全局队列
dispatch_queue_tqueue =dispatch_get_global_queue(0,0);
//调度组的异步请求
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:3];
NSLog(@"下载第一张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:2];
NSLog(@"下载第二张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:4];
NSLog(@"下载第三张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:1];
NSLog(@"下载第四张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:6];
NSLog(@"下载第五张图片");
});
dispatch_group_async(group, queue, ^{
[NSThreadsleepForTimeInterval:5];
NSLog(@"下载第六张图片");
});
dispatch_group_wait(group,DISPATCH_TIME_FOREVER);
NSLog(@"刷新UI");
}
DISPATCH_TIME_FOREVER 的打印结果
DISPATCH_TIME_FOREVER：等待所有完成之后才进行下面的操作，任务没有完成，会一直等待；
2017-06-23 02:23:20.459 GCD的研究[4236:303625]下载第四张图片
2017-06-23 02:23:21.459 GCD的研究[4236:303626]下载第二张图片
2017-06-23 02:23:22.459 GCD的研究[4236:303639]下载第一张图片
2017-06-23 02:23:23.459 GCD的研究[4236:303628]下载第三张图片
2017-06-23 02:23:24.461 GCD的研究[4236:303642]下载第六张图片
2017-06-23 02:23:25.463 GCD的研究[4236:303641]下载第五张图片
2017-06-23 02:23:25.463 GCD的研究[4236:303334]刷新UI
/ DISPATCH_TIME_NOW 不用判断队列是否处理完,即不等待，就调用
打印结果为：
2017-06-23 02:26:34.723 GCD的研究[4253:305624]刷新UI
2017-06-23 02:26:35.723 GCD的研究[4253:305696]下载第四张图片
2017-06-23 02:26:36.723 GCD的研究[4253:305668]下载第二张图片
2017-06-23 02:26:37.726 GCD的研究[4253:305667]下载第一张图片
2017-06-23 02:26:38.723 GCD的研究[4253:305670]下载第三张图片
2017-06-23 02:26:39.727 GCD的研究[4253:305698]下载第六张图片
2017-06-23 02:26:40.727 GCD的研究[4253:305697]下载第五张图片
Enter和Leave
作用其实跟group函数一样，当enter之后，对应的leave出来才会往下执行
- (void)groupTest4
{
dispatch_group_tgroup =dispatch_group_create();
dispatch_queue_tqueue =dispatch_get_global_queue(0,0);
//进入队列
dispatch_group_enter(group);
dispatch_async(queue, ^{
NSLog(@"下载第三张图片");
});
dispatch_async(queue, ^{
NSLog(@"下载第四张图片");
});
dispatch_async(queue, ^{
NSLog(@"下载第二张图片");
});
dispatch_async(queue, ^{
NSLog(@"下载第一张图片");
});
dispatch_async(queue, ^{
NSLog(@"下载第五张图片");
//离开队列
dispatch_group_leave(group);
NSLog(@"更新UI");
});
}
打印结果
2017-06-23 02:44:21.396 GCD的研究[4451:318227]下载第四张图片
2017-06-23 02:44:21.396 GCD的研究[4451:318226]下载第二张图片
2017-06-23 02:44:21.396 GCD的研究[4451:318243]下载第三张图片
2017-06-23 02:44:21.396 GCD的研究[4451:318229]下载第一张图片
2017-06-23 02:44:21.397 GCD的研究[4451:318227]下载第五张图片
2017-06-23 02:44:21.397 GCD的研究[4451:318226]更新UI
barrier函数(栅栏函数)
barrier函数与dispatch_queue_create函数生成的concurrent队列一起使用
- (void)barrier
{
dispatch_queue_t queue =dispatch_queue_create("1",DISPATCH_QUEUE_CONCURRENT);
dispatch_async(queue, ^{
NSLog(@"----1------%@",[NSThreadcurrentThread]);
});
dispatch_async(queue, ^{
NSLog(@"----2------%@",[NSThreadcurrentThread]);
});
dispatch_barrier_async(queue, ^{
NSLog(@"--barrier--%@",[NSThreadcurrentThread]);
});
dispatch_async(queue, ^{
NSLog(@"----3------%@",[NSThreadcurrentThread]);
});
}
打印结果
2017-06-23 02:51:05.029 GCD的研究[4675:325885] ----1------{number = 3, name = (null)}
2017-06-23 02:51:05.030 GCD的研究[4675:325873] ----2------{number = 4, name = (null)}
2017-06-23 02:51:05.031 GCD的研究[4675:325873] --barrier--{number = 4, name = (null)}
2017-06-23 02:51:05.031 GCD的研究[4675:325873] ----3------{number = 4, name = (null)}
栅栏函数的作用和其名字相近，就是在一个线程队列中当一个栅栏的作用
信号量
dispatch_semaphore_create 创建一个信号总量
dispatch_semaphore_signal 发送一个信号，让信号总量+1
dispatch_semaphore_wait 等待信号，当信号总量少于0的时候就会一直等待，否则就可以正常的执行，并让信号总量-1
根据这样的原理，我们可以创建一个并发控制来同步任务和有限资源访问控制。
- (void)signal
{
dispatch_group_tgroup =dispatch_group_create();
dispatch_semaphore_tsemaphore =dispatch_semaphore_create(10);
dispatch_queue_tqueue =dispatch_get_global_queue(0,0);
for(inti =0; i <100; i++) {
//信号等待使信号总量-1,开始为10-1=9继续往下执行
dispatch_semaphore_wait(semaphore,DISPATCH_TIME_FOREVER);
//将一个并发任务关联到Group
dispatch_group_async(group, queue, ^{
NSLog(@"%i",i);
sleep(2);
//发送一个信号信号总量+1如果+1前信号总量小于1了即刻有可以开始执行之前的等待位置
dispatch_semaphore_signal(semaphore);
});
}
//等待group相关的所有任务执行完成才往下走
dispatch_group_wait(group,DISPATCH_TIME_FOREVER);
NSLog(@"更新UI");
}
打印结果显示，每次打印十个，待所有任务执行完成 更新UI
其实类似于NSOperationQueue中设置最大并发数；
