多线程开发是平常开发任务中不可缺乏的一部分,在iOS开发中经常使用到的多线程开发技术有
GCD、NSOperation、NSThread
,本文主要讲解多线系列文章中关于NSOperation
的相关知识和使用详解。html
GCD
对于iOS开发者来讲并不陌生,在实际开发中咱们会常常用到GCD进行多线程的处理,那么GCD是什么呢?编程
Grand Central Dispatch(GCD) 是 Apple 开发的一个多核编程的较新的解决方法。它主要用于优化应用程序以支持多核处理器以及其余对称多处理系统。它是一个在线程池模式的基础上执行的并发任务。在 Mac OS X 10.6 雪豹中首次推出,也可在 iOS 4 及以上版本使用。安全
GCD有着很明显的优点,正是这些优点才使得GCD在处理多线程问题有着举足轻重的地位。bash
- GCD是apple为多核的并行运算提出的解决方案。
- GCD能较好的利用CPU内核资源。
- GCD不须要开发者去管理线程的生命周期。
- 使用简便,开发者只须要告诉GCD执行什么任务,并不须要编写任何线程管理代码。
相信不少初级开发者会对GCD任务和队列之间的关系理解含糊不清,实际上队列只是提供了保存任务的容器。为了更好的理解GCD,颇有必要先了解任务和队列的概念。网络
任务就是须要执行的操做,是GCD中放在block中在线程中执行的那段代码。任务的执行的方式有同步执行和异步执行两中执行方式。二者的主要区别是是否等待队列的任务执行结束,以及是否具有开启新线程的能力。多线程
队列:队列是一种特殊的线性表,队列中容许插入操做的一端称为队尾,容许删除操做的一端称为队头,是一种先进先出的结构。在GCD里面队列是指执行任务的等待队列,是用来存听任务的。按照队列的结构特性,新任务老是插入在队列的末尾,而任务的执行老是从队列的对头输出,每读取一个任务,则从队列中释放一个任务。GCD的队列分为串行队列和并发队列两种,二者都符合 FIFO(先进先出)的原则。二者的主要区别是:执行顺序不一样,以及开启线程数不一样。并发
二者之间区别以下图所示: app
GCD的使用很简单,首先建立一个队列,而后向队列中追加任务,系统会根据任务的类型执行任务。异步
dispatch_queue_create
方法传入相对应的参数即可。这个方法有两个参数:DISPATCH_QUEUE_SERIAL
表示串行队列,DISPATCH_QUEUE_CONCURRENT
表示并发队列。// 建立串行队列
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_SERIAL);
// 建立并发队列
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_CONCURRENT);
复制代码
dispatch_get_global_queue
方法来获取全局并发队列。这个方法须要传入两个参数。DISPATCH_QUEUE_PRIORITY_HIGH
、DISPATCH_QUEUE_PRIORITY_LOW
、DISPATCH_QUEUE_PRIORITY_BACKGROUND
、DISPATCH_QUEUE_PRIORITY_DEFAULT
四个选项,通常用 DISPATCH_QUEUE_PRIORITY_DEFAULT
。// 获取全局并发队列
dispatch_queue_t globalQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
复制代码
dispatch_get_main_queue
方法获取,全部放在主队列中的任务都会在主线程中执行。主队列是一种串行队列。// 主队
dispatch_queue_t mainQueue = dispatch_get_main_queue();
复制代码
GCD调用dispatch_sync
建立同步任务,调用dispatch_async
建立异步任务。任务的内容都是在block代码块中。async
//异步任务
dispatch_async(queue, ^{
//异步执行的代码
});
//同步任务
dispatch_sync(queue, ^{
//同步执行的代码
});
复制代码
建立的任务须要放在队列中去执行,同时考虑到主队列的特殊性,那么在不考虑嵌套任务的状况下就会存在同步任务+串行队列、同步任务+并发队列、异步任务+串行队列、异步任务+并发队列、主队列+同步任务、主队列+异步任务六种组合,下面咱们来分析下这几种组合。
下面咱们来看看各类组合之间的使用。
- (void)syncTaskWithSerial {
NSLog(@"currentThread:%@", [NSThread currentThread]);
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_SERIAL);
dispatch_sync(queue, ^{
NSLog(@"currentThread-1:%@", [NSThread currentThread]);
});
dispatch_sync(queue, ^{
NSLog(@"currentThread-2:%@", [NSThread currentThread]);
});
dispatch_sync(queue, ^{
NSLog(@"currentThread-3:%@", [NSThread currentThread]);
});
}
复制代码
打印结果: 2020-03-12 21:34:25.807965+0800 ThreadDemo[51144:6948582] currentThread:<NSThread: 0x600001739100>{number = 1, name = main} 2020-03-12 21:34:25.808231+0800 ThreadDemo[51144:6948582] currentThread-1:<NSThread: 0x600001739100>{number = 1, name = main} 2020-03-12 21:34:25.808467+0800 ThreadDemo[51144:6948582] currentThread-2:<NSThread: 0x600001739100>{number = 1, name = main} 2020-03-12 21:34:25.808669+0800 ThreadDemo[51144:6948582] currentThread-3:<NSThread: 0x600001739100>{number = 1, name = main}
从上面代码运行的结果能够看出,并无开启新的线程,任务是按顺序执行的。
- (void)syncTaskWithConcurrent {
NSLog(@"current thread:%@", [NSThread currentThread]);
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_CONCURRENT);
dispatch_sync(queue, ^{
NSLog(@"current thread-1:%@", [NSThread currentThread]);
});
dispatch_sync(queue, ^{
NSLog(@"current thread-2:%@", [NSThread currentThread]);
});
dispatch_sync(queue, ^{
NSLog(@"current thread-3:%@", [NSThread currentThread]);
});
}
复制代码
打印结果: 2020-03-12 21:39:45.931001+0800 ThreadDemo[51225:6953218] current thread:<NSThread: 0x600002abe0c0>{number = 1, name = main} 2020-03-12 21:39:45.931259+0800 ThreadDemo[51225:6953218] current thread-1:<NSThread: 0x600002abe0c0>{number = 1, name = main} 2020-03-12 21:39:45.931442+0800 ThreadDemo[51225:6953218] current thread-2:<NSThread: 0x600002abe0c0>{number = 1, name = main} 2020-03-12 21:39:45.931606+0800 ThreadDemo[51225:6953218] current thread-3:<NSThread: 0x600002abe0c0>{number = 1, name = main}
从上面代码运行的结果能够看出,同步任务不会开启新的线程,虽然任务在并发队列中,可是系统只默认开启了一个主线程,没有开启子线程,因此任务串行执行。
- (void)asyncTaskWithSeria{
NSLog(@"current thread:%@", [NSThread currentThread]);
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_SERIAL);
dispatch_async(queue, ^{
NSLog(@"current thread-1:%@", [NSThread currentThread]);
});
dispatch_async(queue, ^{
NSLog(@"current thread-2:%@", [NSThread currentThread]);
});
dispatch_async(queue, ^{
NSLog(@"current thread-3:%@", [NSThread currentThread]);
});
NSLog(@"4");
}
复制代码
打印结果: 2020-03-12 21:44:22.369058+0800 ThreadDemo[51283:6957598] current thread:<NSThread: 0x6000031891c0>{number = 1, name = main} 2020-03-12 21:44:22.369279+0800 ThreadDemo[51283:6957598] 4 2020-03-12 21:44:22.369346+0800 ThreadDemo[51283:6958684] current thread-1:<NSThread: 0x6000031acb80>{number = 7, name = (null)} 2020-03-12 21:44:22.369511+0800 ThreadDemo[51283:6958684] current thread-2:<NSThread: 0x6000031acb80>{number = 7, name = (null)} 2020-03-12 21:44:22.369675+0800 ThreadDemo[51283:6958684] current thread-3:<NSThread: 0x6000031acb80>{number = 7, name = (null)}
从上面代码运行的结果能够看出,开启了一个新的线程,说明异步任务具有开启新的线程的能力,可是因为任务是在串行队列中执行的,因此任务是顺序执行的。
- (void)asyncTaskWithConcurrent{
NSLog(@"current thread:%@", [NSThread currentThread]);
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_CONCURRENT);
dispatch_async(queue, ^{
NSLog(@"current thread-1:%@", [NSThread currentThread]);
});
dispatch_async(queue, ^{
NSLog(@"current thread-2:%@", [NSThread currentThread]);
});
dispatch_async(queue, ^{
NSLog(@"current thread-3:%@", [NSThread currentThread]);
});
dispatch_async(queue, ^{
NSLog(@"current thread-4:%@", [NSThread currentThread]);
});
}
复制代码
打印结果: 2020-03-12 21:59:36.511770+0800 ThreadDemo[51635:6976397] current thread:<NSThread: 0x60000024ed00>{number = 1, name = main} 2020-03-12 21:59:36.512015+0800 ThreadDemo[51635:6976575] current thread-2:<NSThread: 0x600000214ec0>{number = 5, name = (null)} 2020-03-12 21:59:36.512011+0800 ThreadDemo[51635:6976577] current thread-1:<NSThread: 0x600000215700>{number = 4, name = (null)} 2020-03-12 21:59:36.512028+0800 ThreadDemo[51635:6976580] current thread-3:<NSThread: 0x60000021f2c0>{number = 6, name = (null)} 2020-03-12 21:59:36.512035+0800 ThreadDemo[51635:6976578] current thread-4:<NSThread: 0x60000023b340>{number = 7, name = (null)}
从上面代码的运行结果能够看出,生成了多个线程,而且任务是随机执行(并发执行)的。
-(void)syncTaskWithMain{
NSLog(@"currentThread---%@",[NSThread currentThread]);
dispatch_queue_t queue = dispatch_get_main_queue();
dispatch_sync(queue, ^{
NSLog(@"1---%@",[NSThread currentThread]);
});
dispatch_sync(queue, ^{
NSLog(@"2---%@",[NSThread currentThread]);
});
dispatch_sync(queue, ^{
NSLog(@"3---%@",[NSThread currentThread]);
});
NSLog(@"4");
}
复制代码
打印结果: 2020-03-12 22:05:01.689594+0800 ThreadDemo[51754:6982402] currentThread---<NSThread: 0x600003eaed00>{number = 1, name = main} (lldb)
很明显上面这段代码运行崩溃了,这是由于咱们在主线程中执行 syncTaskWithMain
方法,至关于把 syncTaskWithMain
任务放到了主线程的队列中。而 同步执行
会等待当前队列中的任务执行完毕,才会接着执行。那么当咱们把 任务 1
追加到主队列中,任务 1
就在等待主线程处理完 syncTaskWithMain
任务。而syncMain
任务须要等待任务 1
执行完毕,这样就造成了相互等待的状况,产生了死锁。
-(void)asyncTaskWithMain{
NSLog(@"currentThread---%@",[NSThread currentThread]);
dispatch_queue_t queue = dispatch_get_main_queue();
dispatch_async(queue, ^{
NSLog(@"1---%@",[NSThread currentThread]);
});
dispatch_async(queue, ^{
NSLog(@"2---%@",[NSThread currentThread]);
});
dispatch_async(queue, ^{
NSLog(@"3---%@",[NSThread currentThread]);
});
NSLog(@"4");
}
复制代码
打印结果: 2020-03-12 22:09:49.285203+0800 ThreadDemo[51832:6986908] currentThread---<NSThread: 0x600000aff3c0>{number = 1, name = main} 2020-03-12 22:09:49.285539+0800 ThreadDemo[51832:6986908] 4 2020-03-12 22:09:49.326310+0800 ThreadDemo[51832:6986908] 1---<NSThread: 0x600000aff3c0>{number = 1, name = main} 2020-03-12 22:09:49.326749+0800 ThreadDemo[51832:6986908] 2---<NSThread: 0x600000aff3c0>{number = 1, name = main} 2020-03-12 22:09:49.326988+0800 ThreadDemo[51832:6986908] 3---<NSThread: 0x600000aff3c0>{number = 1, name = main}
从上面代码的运行结果能够看出,虽然是异步任务,可是并无开启新的线程,任然是在主线程中执行,而且任务是顺序执行的。
关于任务的嵌套使用有多种状况,这里作一个简单的总结,
区别 | 『异步执行+并发队列』嵌套『同一个并发队列』 | 『同步执行+并发队列』嵌套『同一个并发队列』 | 『异步执行+串行队列』嵌套『同一个串行队列』 | 『同步执行+串行队列』嵌套『同一个串行队列』 |
---|---|---|---|---|
同步 | 没有开启新的线程,串行执行任务 | 没有开启新线程,串行执行任务 | 死锁卡住不执行 | 死锁卡住不执行 |
异步 | 有开启新线程,并发执行任务 | 有开启新线程,并发执行任务 | 有开启新线程(1 条),串行执行任务 | 有开启新线程(1 条),串行执行任务 |
对于**『异步执行+串行队列』嵌套『同一个串行队列』**形成死锁的状况请看以下代码:
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_SERIAL);
//异步任务A
dispatch_async(queue, ^{
//同步任务B
dispatch_sync(queue, ^{
NSLog(@"任务C---%@",[NSThread currentThread]);
});
});
复制代码
首先异步任务A进入到队列中,同步任务B对于异步任务A来讲是代码执行部分,C对于同步任务B来讲是代码执行部分,由于是在串行队列中,任务是串行执行的,根据队列先进先出原则,首先须要把任务A取出执行,即执行B的部分,可是B依赖C的执行,而C等待着B执行完成后执行,这样就造成了一个相互等待,形成死锁卡死。
**同步执行+串行队列』嵌套『同一个串行队列』**形成死锁的状况同理分析。
在 iOS 开发过程当中,咱们在主线程进行UI刷新,把图片下载、文件上传、网络请求等一些耗时的操做放在其余的线程,当这些耗时的操做完成后须要将数据同步给UI,就须要回到主线程刷新UI,那么就要用到线程之间的通信。GCD提供了很是简便的方法进行线程间的通信。
- (void)communication {
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_CONCURRENT);
dispatch_async(queue, ^{
NSLog(@"1---%@",[NSThread currentThread]);
// 模拟耗时操做
sleep(2);
// 回到主线程
dispatch_async(dispatch_get_main_queue(), ^{
NSLog(@"2---%@",[NSThread currentThread]); // 打印当前线程
});
});
}
复制代码
打印结果 2020-03-13 00:06:07.632014+0800 ThreadDemo[53480:7074047] 1---<NSThread: 0x60000063e480>{number = 5, name = (null)} 2020-03-13 00:06:09.633041+0800 ThreadDemo[53480:7073841] 2---<NSThread: 0x60000061a180>{number = 1, name = main}
从上面代码运行的结果能够看出,1是在子线程中执行的,隔2秒后打印2,2是在主线程中执行的。
GCD中提供了诸多的函数方法供开发者调用,咱们一块儿来看下这些方法的使用。
有的时候咱们须要异步执行两组操做,等待第一组执行完成后才回去执行第二组操做,这个时候栅栏方法就起做用了。 栅栏方法(dispatch_barrier_async
或dispatch_barrier_sync
)会等前边追加到队列中的任务执行完毕后,再将制定的任务追加到队列中,而后等到dispatch_barrier_async
或dispatch_barrier_sync
方法追加的任务执行完毕后才会去执行后边追加到队列中的任务,简单来讲dispatch_barrier_async
或dispatch_barrier_sync
将异步任务分红了两个组,执行完第一组后,再执行本身,而后执行队列中剩余的任务。惟一不一样的是dispatch_barrier_async
不会阻塞线程。
看以下代码:
- (void)barrierTask {
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_CONCURRENT);
NSLog(@"start");
dispatch_async(queue, ^{
NSLog(@"currentThread-1:%@", [NSThread currentThread]);
});
dispatch_barrier_async(queue, ^{
NSLog(@"currentThread-2:%@", [NSThread currentThread]);
[NSThread sleepForTimeInterval:2];
});
NSLog(@"pause");
dispatch_async(queue, ^{
NSLog(@"currentThread-3:%@", [NSThread currentThread]);
});
NSLog(@"end");
}
复制代码
打印结果 2020-03-13 00:31:53.247514+0800 ThreadDemo[54101:7100220] start 2020-03-13 00:31:53.247730+0800 ThreadDemo[54101:7100220] pause 2020-03-13 00:31:53.247809+0800 ThreadDemo[54101:7100396] currentThread-1:<NSThread: 0x600003b8db00>{number = 5, name = (null)} 2020-03-13 00:31:53.247883+0800 ThreadDemo[54101:7100220] end 2020-03-13 00:31:53.247991+0800 ThreadDemo[54101:7100396] currentThread-2:<NSThread: 0x600003b8db00>{number = 5, name = (null)} 2020-03-13 00:31:55.250622+0800 ThreadDemo[54101:7100396] currentThread-3:<NSThread: 0x600003b8db00>{number = 5, name = (null)}
从上面的代码运行结果能够看出,start、pause、end都是在2执行答应的,说明dispatch_barrier_async并无阻塞线程,3是在2打印两秒后打印的。
若是把dispatch_barrier_async换成dispatch_barrier_sync打印结果会是怎么样呢?
- (void)barrierTask {
dispatch_queue_t queue = dispatch_queue_create("com.shen.thread.demo", DISPATCH_QUEUE_CONCURRENT);
NSLog(@"start");
dispatch_async(queue, ^{
NSLog(@"currentThread-1:%@", [NSThread currentThread]);
});
dispatch_barrier_sync(queue, ^{
NSLog(@"currentThread-2:%@", [NSThread currentThread]);
[NSThread sleepForTimeInterval:2];
});
NSLog(@"pause");
dispatch_async(queue, ^{
NSLog(@"currentThread-3:%@", [NSThread currentThread]);
});
NSLog(@"end");
}
复制代码
打印结果 2020-03-13 00:35:01.460109+0800 ThreadDemo[54171:7103212] start 2020-03-13 00:35:01.460408+0800 ThreadDemo[54171:7103379] currentThread-1:<NSThread: 0x600002508540>{number = 6, name = (null)} 2020-03-13 00:35:01.460588+0800 ThreadDemo[54171:7103212] currentThread-2:<NSThread: 0x600002570880>{number = 1, name = main} 2020-03-13 00:35:03.461678+0800 ThreadDemo[54171:7103212] pause 2020-03-13 00:35:03.462012+0800 ThreadDemo[54171:7103212] end 2020-03-13 00:35:03.462145+0800 ThreadDemo[54171:7103379] currentThread-3:<NSThread: 0x600002508540>{number = 6, name = (null)}
从上面代码运行的结果能够看出,pause和end是在2以后打印的,说明dispatch_barrier_sync阻塞了线程,须要等待dispatch_barrier_sync执行完成后才会日后执行。
延时执行任务相信对于iOS开发者来讲并不陌生,咱们常常遇到须要在延后指定之间后执行某个操做的需求,那么这种需求用GCD来实现是很方便的。GCD的延时执行的函数是dispatch_after
。须要注意的是:dispatch_after
方法并非在指定时间以后才开始执行处理,而是在指定时间以后将任务追加到主队列中。严格来讲,这个时间并非绝对准确的,但想要大体延迟执行任务,dispatch_after
方法是颇有效的。
-(void)afterTask{
NSLog(@"begin");
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3.0*NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
NSLog(@"after---%@",[NSThread currentThread]);
});
}
复制代码
打印结果 2020-03-13 00:43:47.787769+0800 ThreadDemo[54378:7111012] begin 2020-03-13 00:43:50.788086+0800 ThreadDemo[54378:7111012] after---<NSThread: 0x60000042ddc0>{number = 1, name = main}
从上面代码的运行结果能够看出afer是在begin打印后3秒才打印的。
GCD提供了只执行一次的方法dispatch_once
,这个方法在咱们建立单例的时候回常常用到。dispatch_once
方法能够保证一段代码在程序运行过程当中只被调用一次,并且在多线程环境下能够保证线程安全。
+ (instancetype)shareInstance{
static Test *instance = nil;
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
instance = [Test alloc]init];
});
return instance;
}
复制代码
调度组简单来讲就是把异步执行的任务进行分组,等待全部的分组任务都执行完毕后再回到指定的线程执行任务。调用组使用dispatch_group_create
来建立一个分组,dispatch_group_async
方法先把任务添加到队列中,而后将队列方到调度组中,或者也可使用dispatch_group_enter
和dispatch_group_leave
捉对实现将队列添加到调度组。调用dispatch_group_notify
方法回到指定线程执行任务,或者调用dispatch_group_wait
阻塞当前线程。
- (void)groupNotifyTest{
NSLog(@"current thread:%@", [NSThread currentThread]);
dispatch_group_t group = dispatch_group_create();
dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
[NSThread sleepForTimeInterval:2];
NSLog(@"thread-1:%@", [NSThread currentThread]);
});
dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
[NSThread sleepForTimeInterval:2];
NSLog(@"thread-2:%@", [NSThread currentThread]);
});
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
[NSThread sleepForTimeInterval:2];
NSLog(@"thread-3:%@", [NSThread currentThread]);
NSLog(@"group-end");
});
//会阻塞线程,
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
NSLog(@"dispatch_group_wait后继续执行任务");
}
复制代码
打印结果: 2020-03-14 23:58:09.871023+0800 ThreadDemo[77370:8259501] current thread:<NSThread: 0x6000019fe480>{number = 1, name = main} 2020-03-14 23:58:11.874345+0800 ThreadDemo[77370:8260290] thread-2:<NSThread: 0x600001996e80>{number = 7, name = (null)} 2020-03-14 23:58:11.874343+0800 ThreadDemo[77370:8259684] thread-1:<NSThread: 0x6000019a55c0>{number = 5, name = (null)} 2020-03-14 23:58:11.874672+0800 ThreadDemo[77370:8259501] dispatch_group_wait后继续执行任务 2020-03-14 23:58:13.877077+0800 ThreadDemo[77370:8259501] thread-3:<NSThread: 0x6000019fe480>{number = 1, name = main} 2020-03-14 23:58:13.877365+0800 ThreadDemo[77370:8259501] group-end
在这里须要说明的一点是
dispatch_group_wait
,该方法须要传入两个参数,第一个参数是group即调度组,第二个参数是timerout即指定等待的时间。一旦调用dispatch_group_wait
函数,该函数就处理调用的状态而不返回值,只有当函数的currentThread中止,或到达wait函数指定的等待的时间,或Dispatch Group
中的操做所有执行完毕以前,执行该函数的线程中止。当指定timeout为DISPATCH_TIME_FOREVER
时就意味着永久等待;当指定timeout为DISPATCH_TIME_NOW
时就意味不用任何等待便可断定属于Dispatch Group
的处理是否所有执行结束。若是dispatch_group_wait
函数返回值不为0,就意味着虽然通过了指定的时间,但Dispatch Group
中的操做并未所有执行完毕。若是dispatch_group_wait
函数返回值为0,就意味着Dispatch Group
中的操做所有执行完毕。
下面看dispatch_group_enter
和dispatch_group_leave
捉对实现将队列添加到调度组的状况。dispatch_group_enter
标志着在group的任务数+1,dispatch_group_leave
标志着在group中的任务数-1,表示已经完成了一个任务。
- (void)groupEnterTest {
dispatch_group_t group = dispatch_group_create();
dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
dispatch_group_enter(group);
dispatch_async(queue, ^{
[NSThread sleepForTimeInterval:2];
NSLog(@"thread_1:%@", [NSThread currentThread]);
dispatch_group_leave(group);
});
dispatch_group_enter(group);
dispatch_async(queue, ^{
[NSThread sleepForTimeInterval:2];
NSLog(@"thread_2:%@", [NSThread currentThread]);
dispatch_group_leave(group);
});
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
[NSThread sleepForTimeInterval:2];
NSLog(@"thread_3:%@", [NSThread currentThread]);
NSLog(@"group_end");
});
}
复制代码
打印结果: 2020-03-15 00:07:17.293333+0800 ThreadDemo[77525:8269621] thread_2:<NSThread: 0x600002434ac0>{number = 7, name = (null)} 2020-03-15 00:07:17.293320+0800 ThreadDemo[77525:8269427] thread_1:<NSThread: 0x60000241b9c0>{number = 3, name = (null)} 2020-03-15 00:07:19.294186+0800 ThreadDemo[77525:8269235] thread_3:<NSThread: 0x600002450b80>{number = 1, name = main} 2020-03-15 00:07:19.294485+0800 ThreadDemo[77525:8269235] group_end
须要注意的是
dispatch_group_enter
和dispatch_group_leave
捉对出现的。
GCD中的信号量是指的Dispatch Semaphore
,是持有计数的信号。当信号量小于0时就会一直等待即阻塞所在线程,不然就能够正常执行。信号量能够保持线程的同步,将异步执行任务转换成同步任务执行, 同时保持线程的安全。
Dispatch Semaphore提供了三个方法:
dispatch_semaphore_create
:建立一个 Semaphore 并初始化信号的总量dispatch_semaphore_signal
:发送一个信号,让信号总量加 1dispatch_semaphore_wait
:可使总信号量减 1,信号总量小于 0 时就会一直等待(阻塞所在线程),不然就能够正常执行。- (void)semaphoreTest {
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
__block int a = 0;
while (a < 5) {
dispatch_async(dispatch_get_global_queue(0, 0), ^{
NSLog(@"里面的a的值:%d-----%@", a, [NSThread currentThread]);
dispatch_semaphore_signal(semaphore);
a++;
});
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
}
NSLog(@"外面的a的值:%d", a);
}
复制代码
打印结果: 2020-03-15 00:44:53.005899+0800 ThreadDemo[78303:8318841] 里面的a的值:0-----<NSThread: 0x600003c222c0>{number = 3, name = (null)} 2020-03-15 00:44:53.006161+0800 ThreadDemo[78303:8318841] 里面的a的值:1-----<NSThread: 0x600003c222c0>{number = 3, name = (null)} 2020-03-15 00:44:53.006354+0800 ThreadDemo[78303:8318841] 里面的a的值:2-----<NSThread: 0x600003c222c0>{number = 3, name = (null)} 2020-03-15 00:44:53.006551+0800 ThreadDemo[78303:8318841] 里面的a的值:3-----<NSThread: 0x600003c222c0>{number = 3, name = (null)} 2020-03-15 00:44:53.006727+0800 ThreadDemo[78303:8318841] 里面的a的值:4-----<NSThread: 0x600003c222c0>{number = 3, name = (null)} 2020-03-15 00:44:53.006862+0800 ThreadDemo[78303:8318672] 外面的a的值:5
调度源是协调特殊低级别系统事件处理的基本数据类型。GCD支持诸如定时器调度源、信号调度源、描述符调度源、进程调度源、端口调度源、自定义调度源等。调度源有这一系列的成熟API,在这里就很少作描述,详细能够查阅官方的文档Dispatch Sources。