先列一下本篇文章所整理的提纲
1.GCD的延迟运行
2.使用Dispatch_group进行线程同步处理
3.使用dispatch_barrier函数(栅栏函数)给访问对象加同步锁
4.同步执行队列函数dispatch_sync
5.使用dispatch_apply遍历数组执行任务
一、GCD延迟执行
我们在工作中有可能回碰到需要延迟执行某些命令的需求。在学习GCD之前我们可以通过
[self performSelector:@selector(abc:) withObject:nil afterDelay:2];
来延迟执行某些任务。但是使用这些方法有一些不方便的地方。首先可以带的参数比较少。第二就是在不同线程中执行的时候不如GCD方便。
使用GCD的方法如下、
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
NSLog(@"test");
});
方法讲解:1.参数dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)代表从当前的时间延迟3s后执行
DISPATCH_TIME_NOW代表从当前时间。
类似的还有DISPATCH_TIME_FOREVER这个通常用在等待某些方法执行完成的时候使用例如dispatch_wait函数来判断添加到队列中的任务是否已经完成。
2.参数2决定在什么队列中执行要添加到队列中的任务。本例中代表被添加的输出test字符串在主线程中运行。
二、dispatch_group函数
使用场景:项目中的任务执行在很多情况下是有顺序的。例如对任务B对数据进行缓存执行之前。可能需要调用两个数据请求获得数据X和数据Y。当数据X和Y同时完成了数据请求之后。才能执行任务B。我们自然可以使用串行队列。按照X->Y->B的任务添加顺序去执行任务。但是某些任务可能非常耗时。这样会浪费大量的时间。而且不能有效的利用系统提供的多线程技术来加快任务的执行速度。这显然是不合适的。在这种情况下Dispatc_group就排上用场了。
我们可以使用多线程取获取X和Y然后当X、Y都完成的时候再去执行B。
使用代码如下:
dispatch_queue_t queueGlobal = dispatch_queue_create("globalQueue", DISPATCH_QUEUE_CONCURRENT);
//创建一个并行队列
dispatch_group_t groupBase = dispatch_group_create();
//创建一个Dispatch_group
dispatch_group_async(groupBase, queueGlobal, ^{
//任务X
for (NSInteger i = 0; i < 10; i++){
if (i == 9) NSLog(@"X马上执行完成");
}
});
//异步将任务X添加到groupBase的queueGlobal队列上
dispatch_group_async(groupBase, queueGlobal, ^{
//任务Y
for (NSInteger i = 0; i < 10; i++){
if (i == 9) NSLog(@"Y马上执行完成");
}
});
//异步将任务Y添加到groupBase的queueGlobal队列上
dispatch_group_notify(groupBase, queueGlobal, ^{
//任务B
NSLog(@"B任务开始执行");
});
//等待groupBase上的任务执行完成的时候执行任务B
调试输出框输出为
2018-01-17 23:14:14.592177+0800 GCD二[16104:486560] X马上执行完成
2018-01-17 23:14:14.593407+0800 GCD二[16104:486558] Y马上执行完成
2018-01-17 23:14:14.601304+0800 GCD二[16104:486560] B任务开始执行
通过以上我们可以清晰的分析得出。通过dispatch_group可以对并行队列进行线程同步处理
(2)dispatch_group_wait函数分析
等待dispatch_group执行完成除了可以使用dispatch_group_notify还可以使用dispatch_group_wait函数。使用如下
dispatch_queue_t queueGlobal = dispatch_queue_create("globalQueue", DISPATCH_QUEUE_CONCURRENT);
dispatch_group_t groupBase = dispatch_group_create();
dispatch_group_async(groupBase, queueGlobal, ^{
//任务X
for (NSInteger i = 0; i < 10; i++){
if (i == 9) NSLog(@"X马上执行完成");
}
});
dispatch_group_async(groupBase, queueGlobal, ^{
//任务Y
for (NSInteger i = 0; i < 10; i++){
if (i == 9) NSLog(@"Y马上执行完成");
}
});
BOOL isComplete = dispatch_group_wait(groupBase, DISPATCH_TIME_FOREVER);
NSLog(@"%d",isComplete);
调试输出为
2018-01-17 23:20:16.809152+0800 GCD二[16145:489420] Y马上执行完成
2018-01-17 23:20:16.809152+0800 GCD二[16145:489418] X马上执行完成
2018-01-17 23:20:16.812577+0800 GCD二[16145:489332] 0
DISPATCH_TIME_FOREVER代表一直等待下去直到dispatch_group中的任务执行完成。等待期间执行dispatch_group_wait函数的线程(当前线程)会一直被堵塞。而dispatch_group_notify则不会。所以我们平时在使用中还是多使用dispatch_group_notify函数比较好。
三、dispatch_barrier_async栅栏函数的使用
在运行一些耗时操作的时候。使用多线程技术我们可以极大的提高我们的任务执行效率。但是使用多线程技术也会带来一些问题。比如对一些数据进行写入操作。
1.对同一个数据不能够同时执行两次写入操作,
2.在进行写入过程的时候能够加上同步锁。拒绝执行读取操作。
但是我们又不想舍弃多线程技术。在这种情景下dispatch_barrier_async函数就派上用上了。
使用如下:
objectA.h
#import <Foundation/Foundation.h>
@interface ObjectA : NSObject
@property (nonatomic, copy) NSString *baseString;
@end
ViewController.m
ObjectA *object = [[ObjectA alloc]init];
object.baseString = @"testABC";
dispatch_queue_t globalDefaultQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
for (NSInteger i = 0; i < 20; i++){
dispatch_async(globalDefaultQueue, ^{
NSLog(@"%@ --- %ld",object.baseString,i);
});
if (i == 10){
dispatch_barrier_async(globalDefaultQueue, ^{
object.baseString = @"ABC";
});
}
}
执行结果如下:
2018-01-17 23:35:01.010879+0800 GCD二[16289:497032] testABC --- 10
2018-01-17 23:35:01.008748+0800 GCD二[16289:497017] testABC --- 2
2018-01-17 23:35:01.008760+0800 GCD二[16289:497016] testABC --- 3
2018-01-17 23:35:01.008921+0800 GCD二[16289:497025] testABC --- 4
2018-01-17 23:35:01.009424+0800 GCD二[16289:497026] testABC --- 5
2018-01-17 23:35:01.009437+0800 GCD二[16289:497027] testABC --- 6
2018-01-17 23:35:01.009864+0800 GCD二[16289:497029] testABC --- 7
2018-01-17 23:35:01.010640+0800 GCD二[16289:497031] testABC --- 8
2018-01-17 23:35:01.010659+0800 GCD二[16289:497030] testABC --- 9
2018-01-17 23:35:01.008200+0800 GCD二[16289:497015] testABC --- 0
2018-01-17 23:35:01.008227+0800 GCD二[16289:497014] testABC --- 1
2018-01-17 23:35:01.011883+0800 GCD二[16289:497033] ABC --- 11
2018-01-17 23:35:01.012994+0800 GCD二[16289:497034] ABC --- 12
2018-01-17 23:35:01.013015+0800 GCD二[16289:497035] ABC --- 13
2018-01-17 23:35:01.013565+0800 GCD二[16289:497036] ABC --- 14
2018-01-17 23:35:01.014066+0800 GCD二[16289:497037] ABC --- 15
2018-01-17 23:35:01.014870+0800 GCD二[16289:497038] ABC --- 16
2018-01-17 23:35:01.029353+0800 GCD二[16289:497039] ABC --- 17
2018-01-17 23:35:01.030392+0800 GCD二[16289:497040] ABC --- 18
2018-01-17 23:35:01.030875+0800 GCD二[16289:497041] ABC --- 19
我们可以得出结论。在同一个线程中通过栅栏函数执行的时候。可以自动同步锁防止在进行写入数据的时候对同一个数据读取。保证了数据的正确性。