线程任务
同步: 在同一个线程中执行任务，任务没有完成前不返回,会阻塞当前线程; dispatch_sync - GCD中在当前线程中添加一个同步操作
异步: 另外开辟线程执行任务,不影响原来线程中的任务执行;dispatch_async - CGD中另开辟线程中添加一个异步操作
GCD线程队列
主队列: 主线程所在的队列,获取主队列 dispatch_get_main_queue()
// 如: 向主队列中添加异步线程更新UI
dispatch_async(dispatch_get_main_queue(), ^{
// 更新UI操作
[tableView reloadData];
});
全局队列: 全局并发队列,获取默认优先级全局并发队列 dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)(第一个参数为队列的优先级,第二个参数为flags), 多个全局队列执行顺序与优先级有关
// 全局并发队列有四种优先级
/* 队列优先级 高 中(默认) 低 后台
#define DISPATCH_QUEUE_PRIORITY_HIGH 2
#define DISPATCH_QUEUE_PRIORITY_DEFAULT 0
#define DISPATCH_QUEUE_PRIORITY_LOW (-2)
#define DISPATCH_QUEUE_PRIORITY_BACKGROUND INT16_MIN
*/
自定义队列 : 自定义一个串行队列 dispatch_queue_create("customQueue",DISPATCH_QUEUE_SERIAL) (第一个参数为字符常量,为队列的名称,第二个参数为队列的属性-队列的串行与并行属性)
- 串行队列:
// 自定义一个串行队列,添加四个同步任务,任务会在当前队列所在的线程中顺序执行. (如果在添加四个异步任务(即用`dispatch_async`添加任务),会从新开辟<与当前队列所在线程不同>一个线程,在该线程中顺序执行这四个任务)
dispatch_queue_t serialQueue = dispatch_queue_create("com.example.SerialQueue", NULL);
NSLog(@"serialQueue %@ ",[NSThread currentThread]);
dispatch_sync(serialQueue, ^{
NSLog(@"dispatch_sync 1 %@",[NSThread currentThread]);
});
dispatch_sync(serialQueue, ^{
sleep(2);
NSLog(@"dispatch_sync 2 %@",[NSThread currentThread]);
});
dispatch_sync(serialQueue, ^{
NSLog(@"dispatch_sync 3 %@",[NSThread currentThread]);
});
dispatch_sync(serialQueue, ^{
NSLog(@"dispatch_sync 4 %@",[NSThread currentThread]);
});
dispatch_sync(serialQueue, ^{
NSLog(@"dispatch_sync 5 %@",[NSThread currentThread]);
});
- 并行队列
// 创建一个并行队列,向队列中添加四个并发任务,每个任务都会开辟一个不同的线程,四个任务同时开始执行(如果向并行队列中添加同步任务,和在串行队列中添加同步任务相同效果)
dispatch_queue_t concurrentQueue= dispatch_queue_create("com.example.ConcurrentQueue", DISPATCH_QUEUE_CONCURRENT);
NSLog(@"concurrentQueue %@",[NSThread currentThread]);
dispatch_async(concurrentQueue, ^{
NSLog(@"dispatch_async 1 %@",[NSThread currentThread]);
});
dispatch_async(concurrentQueue, ^{
sleep(3);
NSLog(@"dispatch_async 2 %@",[NSThread currentThread]);
});
dispatch_async(concurrentQueue, ^{
NSLog(@"dispatch_async 3 %@",[NSThread currentThread]);
});
dispatch_async(concurrentQueue, ^{
NSLog(@"dispatch_async 4 %@",[NSThread currentThread]);
});
常用 Dispatch 方法
dispatch_once : 在应用程序的整个生命周期里,只执行一次
// 单例初始化方法
static SJManager *sjmanager = nil;
- (instancetype)shareManager {
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
sjmanager = [[SJManager alloc] init];
});
return sjmanager;
}
dispatch_after : 线程任务延时执行
// 在主队列中添加一个5秒后的打印操作
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(5 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
NSLog(@"我是5秒后才打印出来的呀");
});
// 其中:dispatch_time(DISPATCH_TIME_NOW, (int64_t)(5 * NSEC_PER_SEC)) 为线程时间,
dispatch_barrier_async : 界线 异步任务, 一般用于并发队列中,在它之前的任务执行完成后执行,它执行完成后才执行它之后的任务
// 任务1,2执行完之后执行任务3,任务3执行完后执行任务4,5
dispatch_queue_t queue = dispatch_queue_create("barrierQueue", DISPATCH_QUEUE_CONCURRENT);
dispatch_async(queue, ^{
sleep(3);
NSLog(@"任务1");
});
dispatch_async(queue, ^{
NSLog(@"任务2");
});
dispatch_barrier_async(queue, ^{
NSLog(@"任务3");
});
dispatch_async(queue, ^{
sleep(3);
NSLog(@"任务4");
});
dispatch_async(queue, ^{
NSLog(@"任务5");
});
dispatch_group_create : 创建一个任务组,即多个线程任务的组合.
dispatch_group_async : 向任务组中添加异步任务, 不同任务所在队列可以不同.
dispatch_group_async && dispatch_group_notify : 监听队列任务全部完成,完成后执行 dispatch_group_notify 中任务
// 合并汇总结果
dispatch_group_t group = dispatch_group_create();
dispatch_group_async(group, dispatch_get_global_queue(0,0), ^{
// 并行执行的任务1
NSLog(@"并行任务1");
});
dispatch_group_async(group, dispatch_get_global_queue(0,0), ^{
// 并行执行的任务2
sleep(3);
NSLog(@"并行任务2");
});
dispatch_group_async(group, dispatch_get_global_queue(0,0), ^{
// 并行执行的任务3
sleep(3);
NSLog(@"并行任务3");
});
dispatch_group_notify(group, dispatch_get_global_queue(0,0), ^{
// 汇总结果
NSLog(@"执行完成任务");
});
dispatch_group_async && dispatch_group_wait : 等待队列任务完成或超时后继续执行 通过 dispatch_group_wait 返回值(long)判断,超时还是完成(返回0)
// 任务组中四个异步线程, 前三个线程执行完成或执行10s后执行第四个线程
dispatch_group_t group = dispatch_group_create();
dispatch_group_async(group, dispatch_get_global_queue(0,0), ^{
// 并行执行的任务1
NSLog(@"并行任务1");
});
dispatch_group_async(group, dispatch_get_global_queue(0,0), ^{
// 执行的任务2
sleep(3);
NSLog(@"并行任务2");
});
dispatch_group_async(group, dispatch_get_global_queue(0,0), ^{
// 执行的任务3
sleep(3);
NSLog(@"并行任务3");
});
long timeout = dispatch_group_wait(group, dispatch_time(DISPATCH_TIME_NOW, (int64_t)(10 * NSEC_PER_SEC)));
if (timeout == 0) {
NSLog(@"completed");
}
else {
NSLog(@"timeout");
}
dispatch_group_async(group, dispatch_get_global_queue(0,0), ^{
// 执行的任务4
NSLog(@"并行任务4");
});
dispatch_apply : 同时执行多次相同操作
// 无序遍历一个数组
NSArray *arr = @[@"1",@"2",@"3",@"4",@"5"];
dispatch_apply(arr.count, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^(size_t index) {
NSLog(@"%@",arr[(int)index]);
});
