iOS开发之GCD多线程二

线程组

当想要监控任务队列中的全部任务执行完成之后再去做某些操作时,就可以用到dispatch_group_t来进行处理。比如:APP需要下载一些图片,而且要分步去下载这些图片。当这些图片全部下载完成之后,再跳转到二级界面去显示。面对这类的需要,就可以使用线程组来完成。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
-(void)dispatchGroupTest{
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
dispatch_group_t group = dispatch_group_create();

dispatch_group_async(group, queue, ^{
NSLog(@"线程组异步任务1: %@", [NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
NSLog(@"线程组异步任务2: %@", [NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
NSLog(@"线程组异步任务3: %@", [NSThread currentThread]);
});

dispatch_group_notify(group, dispatch_get_main_queue(), ^{
NSLog(@"线程组中的任务执行完成,返回主线程:%@", [NSThread currentThread]);
});

}

1
2
3
4
线程组异步任务2: <NSThread: 0x600002596e40>{number = 5, name = (null)}
线程组异步任务1: <NSThread: 0x6000025bee40>{number = 3, name = (null)}
线程组异步任务3: <NSThread: 0x6000025b3640>{number = 4, name = (null)}
线程组中的任务执行完成,返回主线程:<NSThread: 0x6000025fc600>{number = 1, name = main}

多线程阻塞

强制等待线程组执行完成

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
-(void)dispatchGroupTest{
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
dispatch_group_t group = dispatch_group_create();

dispatch_group_async(group, queue, ^{
NSLog(@"线程组异步任务1: %@", [NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
NSLog(@"线程组异步任务2: %@", [NSThread currentThread]);
});
dispatch_group_async(group, queue, ^{
NSLog(@"线程组异步任务3: %@", [NSThread currentThread]);
});
dispatch_time_t time = dispatch_time(DISPATCH_TIME_NOW, 10ull * NSEC_PER_SEC);
dispatch_group_wait(group, time);
NSLog(@"标识点1");

}
1
2
3
4
线程组异步任务1: <NSThread: 0x6000015e1f40>{number = 3, name = (null)}
线程组异步任务2: <NSThread: 0x6000015feb40>{number = 5, name = (null)}
线程组异步任务3: <NSThread: 0x6000015c1780>{number = 4, name = (null)}
标识点1

dispatch_group_wait(dispatch_group_t group, dispatch_time_t timeout);一旦开始执行这个函数,当前线程就会被阻塞,等待线程组中的所有任务都执行完成之后才能继续执行。timeout这个参数为限制阻塞的时间,当阻塞超过这个时间限制之后,就不再阻塞了。不建议在开发当中使用这个方法强制阻塞线程,特别是主线程。

另一种温柔的阻塞方法

在使用异步处理共享数据时,难免会发生数据竞争的问题。当多个线程同时对共享数据进行读写时,为了保证某个时间点上,数据的准确性,得对写数据操作的并发处理做限制:等待之前已经发出的读操作完成之后,再进行写操作,而且阻塞当前队列的后加任务。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
-(void)dispatchBarrierTest{
dispatch_async(queue, blk0_for_reading);
dispatch_async(queue, blk1_for_reading);
dispatch_async(queue, blk2_for_reading);
dispatch_async(queue, blk3_for_reading);
// 不能保证在0、1、2、3读操作完成之后再对数据进行写操作。会产生脏数据。
dispatch_async(queue, blk_for_waiting);
dispatch_async(queue, blk4_for_reading);
dispatch_async(queue, blk5_for_reading);
dispatch_async(queue, blk6_for_reading);
dispatch_async(queue, blk7_for_reading);
}

-(void)dispatchBarrierTest{
dispatch_async(queue, blk0_for_reading);
dispatch_async(queue, blk1_for_reading);
dispatch_async(queue, blk2_for_reading);
dispatch_async(queue, blk3_for_reading);
// 保证0、1、2、3读操作完成之后再执行写操作。而且等待写操作完成之后,再去执行4、5、6、7读操作。
dispatch_barrier_async(queue, blk_for_waiting);
dispatch_async(queue, blk4_for_reading);
dispatch_async(queue, blk5_for_reading);
dispatch_async(queue, blk6_for_reading);
dispatch_async(queue, blk7_for_reading);
}

挂起任务队列

如果不希望继续执行某个队列中,已经被追加的所有任务时,可以将整个任务队列直接挂起。当然,也可以将某个被挂起的任务队列恢复执行!比如:APP的下载任务队列里面加载了很多的下载任务,但是为了优化性能,先将这个耗性能的任务队列挂起来,等待空闲时,再恢复下载。

1
2
3
4
// 挂起任务队列
dispatch_suspend(queue);
// 恢复任务队列
dispatch_resume(queue);

多线程单例

在多线程的环境下,单例模式会由于多线程的同时触发,导致单例模式产生多个对象。使用dispatch_once方法则可以有效避免这个问题。

1
2
3
4
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
// todo
});

多线程读取大文件

在读取大文件时,如果将文件瓜分成多个小文件,使用多线程并列读取,这样比一般的读取速度快很多。使用Dispatch I/O则可以实现这个需求。

文章目录
  1. 1. 线程组
  2. 2. 多线程阻塞
    1. 2.1. 强制等待线程组执行完成
    2. 2.2. 另一种温柔的阻塞方法
    3. 2.3. 挂起任务队列
  3. 3. 多线程单例
  4. 4. 多线程读取大文件