GCD使用(多线程004)

1. RunLoop介绍

目的

消息类型（事件类型）

常用的循环模式

如何使用

[self performSelector:@selector(demo2) onThread:thread withObject:nil waitUntilDone:NO];
[[NSRunLoop currentRunLoop] addTimer:timer forMode:NSDefaultRunLoopMode];

子线程中的消息循环

[[NSRunLoop currentRunLoop] run];

[[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:3]];

BOOL shouldKeepRunning = YES;        // global
NSRunLoop *theRL = [NSRunLoop currentRunLoop];
while (shouldKeepRunning && [theRL runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]]);

问题演示

NSThread *thread = [[NSThread alloc] init];
[thread start];
[self performSelector:@selector(demo2) onThread:thread withObject:nil waitUntilDone:NO];

NSThread *thread = [[NSThread alloc] initWithTarget:self selector:@selector(demo) object:nil];
[thread start];
[self performSelector:@selector(demo2) onThread:thread withObject:nil waitUntilDone:NO];

..........................

- (void)demo {
NSLog(@"over");
}

2. GCD简介

优点

核心组成部分

任务&队列

如何做

//任务
dispatch_block_t block;
//队列
dispatch_queue_t queue;
//把任务放到队列里
dispatch_async(queue, block);

3. 队列执行任务的方式

同步执行任务

dispatch_sync(dispatch_queue_t queue, dispatch_block_t block);
queue：队列
block：任务

异步执行任务

dispatch_async(dispatch_queue_t queue, dispatch_block_t block);

区别

4. 队列的种类

并发队列（Concurrent Dispatch Queue）

dispatch_queue_t queue = dispatch_queue_create("CONCURRENT", DISPATCH_QUEUE_CONCURRENT);

串行队列（Serial Dispatch Queue）

dispatch_queue_t queue = dispatch_queue_create("SERIAL", DISPATCH_QUEUE_SERIAL);

5. 同步、异步、并发、串行的基本概念

同步和异步决定了要不要开启新的线程

当前

不具备

新的

具备

并发和串行决定了任务的执行方式

（同时）

下一个

6. 串行队列的执行

串行队列的同步执行

#define DISPATCH_QUEUE_SERIAL NULL
//串行队列
//dispatch_queue_t q = dispatch_queue_create("test", NULL);
dispatch_queue_t q = dispatch_queue_create("test", DISPATCH_QUEUE_SERIAL);
for (int i = 0; i < 10; i++) {
//同步执行
dispatch_sync(q, ^{
NSLog(@"%@ -- %d",[NSThread currentThread],i);
});
}

串行队列的异步执行

//只有一个线程，因为是串行队列，只有一个线程就可以按顺序执行队列中的所有任务
dispatch_queue_t q = dispatch_queue_create("test", DISPATCH_QUEUE_SERIAL);
for (int i = 0; i < 10; i++) {
//异步执行
dispatch_async(q, ^{
NSLog(@"%@ -- %d",[NSThread currentThread],i);
});
}

7. 并行队列的执行

并行队列，异步执行

不固定

dispatch_queue_t q = dispatch_queue_create("test", DISPATCH_QUEUE_CONCURRENT);
for (int i = 0; i < 10; i++) {
//异步执行
dispatch_async(q, ^{
NSLog(@"%@ -- %d",[NSThread currentThread],i);
});
}

并行队列，同步执行

串行队列的同步执行

8. 系统提供的队列

主队列

全局并发队列

主队列

dispatch_queue_t queue = dispatch_get_main_queue();

主队列，异步任务

全局串行队列

主队列，同步执行

（死锁）

dispatch_sync(dispatch_get_main_queue(), ^{
NSLog(@"%@ -- %d",[NSThread currentThread],i);
});

全局并发队列

相同

9. 同步异步串行并发的组合结果

没有开启新线程

10. GCD延时函数使用

dispatch_after的定义

dispatch_after(dispatch_time_t when,dispatch_queue_t queue,dispatch_block_t block);

dispatch_after的参数

例子

//延时操作
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
});

11. GCD一次执行和单例实现

// MARK: 一次性执行
- (void)once {
static dispatch_once_t onceToken;
NSLog(@"%ld", onceToken);

dispatch_once(&onceToken, ^{
[NSThread sleepForTimeInterval:1.0];
NSLog(@"一次性吗?");
});
NSLog(@"come here");
}

线程安全

测试

单例的2中实现

+ (instancetype)sharedSingleton {
static id instance;

static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
instance = [[self alloc] init];
});

return instance;
}

+ (instancetype)sharedSync {
static id syncInstance;

@synchronized(self) {
if (syncInstance == nil) {
syncInstance = [[self alloc] init];
}
}

return syncInstance;
}

- (void)touchesBegan:(NSSet *)touches withEvent:(UIEvent *)event {
long largeNumber = 1000 * 1000;

// 测试互斥锁
CFAbsoluteTime start = CFAbsoluteTimeGetCurrent();
for (long i = 0; i < largeNumber; ++i) {
[Singleton sharedSync];
}
NSLog(@"互斥锁： %f", CFAbsoluteTimeGetCurrent() - start);

// 测试 dispatch_once
start = CFAbsoluteTimeGetCurrent();
for (long i = 0; i < largeNumber; ++i) {
[Singleton sharedSingleton];
}
NSLog(@"dispatch_once： %f", CFAbsoluteTimeGetCurrent() - start);
}

12. GCD任务组

/**
调度组-在一组异步代码执行完毕后，统一获得通知

应用场景：将一组图像异步缓存到本地之后统一获得通知！
*/
- (void)group1 {
// 队列
dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
// 调度组
dispatch_group_t group = dispatch_group_create();

// 添加异步
dispatch_group_async(group, queue, ^{
[NSThread sleepForTimeInterval:1.0];
NSLog(@"download A %@", [NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
[NSThread sleepForTimeInterval:0.5];
NSLog(@"download B %@", [NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
NSLog(@"download C %@", [NSThread currentThread]);
});

// 调度组通知 - 监听群组中，所有异步执行的代码完成后，得到通知
// 异步监听！
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
NSLog(@"下载完成 %@", [NSThread currentThread]);
});

NSLog(@"come here");
}

// MARK: - 调度组 2
- (void)group2 {
// 1. 调度组
dispatch_group_t group = dispatch_group_create();

// 2. 队列
dispatch_queue_t q = dispatch_get_global_queue(0, 0);

// dispatch_group_enter & dispatch_group_leave 必须成对出现
dispatch_group_enter(group);
dispatch_group_async(group, q, ^{
NSLog(@"任务 1 %@", [NSThread currentThread]);

// dispatch_group_leave 必须是 block 的最后一句
dispatch_group_leave(group);
});

dispatch_group_enter(group);
dispatch_group_async(group, q, ^{
NSLog(@"任务 2 %@", [NSThread currentThread]);

// dispatch_group_leave 必须是 block 的最后一句
dispatch_group_leave(group);
});

// 4. 阻塞式等待调度组中所有任务执行完毕
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);

// 5. 判断异步
NSLog(@"OVER %@", [NSThread currentThread]);
}

注意：