GCD

GCD之dispatch queue深刻浅出

iOS中多线程编程工具主要有：

•  NSThread
• NSOperation
• GCD

这三种方法都简单易用,各有千秋.但无疑GCD是最有诱惑力的,由于其自己是apple为多核的并行运算提出的解决方案.虽然当前移动平台用双核的很少,但不影响GCD做为多线程编程的利器(ipad2已是双核了,这无疑是一个趋势).

http://www.cnblogs.com/scorpiozj/archive/2011/07/25/2116459.html

GCD是和block紧密相连的,因此最好先了解下block(能够查看这里).GCD是C level的函数,这意味着它也提供了C的函数指针做为参数,方便了C程序员.

1、下面首先来看GCD的使用:

dispatch_async(dispatch_queue_t queue, dispatch_block_t block);

async代表异步运行,block表明的是你要作的事情,queue则是你把任务交给谁来处理了.(除了async,还有sync,delay,本文以async为例).

之因此程序中会用到多线程是由于程序每每会须要读取数据,而后更新UI.为了良好的用户体验,读取数据的操做会倾向于在后台运行,这样以免阻塞主线程.GCD里就有三种queue来处理.

       先来介绍一下 Main queue：

　　顾名思义,运行在主线程,由dispatch_get_main_queue得到.和ui相关的就要使用Main Queue.

[cpp] view plain copy

1. //GCD下载图片刷新主界面的例子  
2. /* 
3. - (IBAction)touchUpInsideByThreadOne:(id)sender { 
4.     dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{ 
5.         NSURL * url = [NSURL URLWithString:@"http://avatar.csdn.net/2/C/D/1_totogo2010.jpg"]; 
6.         NSData * data = [[NSData alloc]initWithContentsOfURL:url]; 
7.         UIImage *image = [[UIImage alloc]initWithData:data]; 
8.         if (data != nil) { 
9.             dispatch_async(dispatch_get_main_queue(), ^{ 
10.                 self.imageView.image = image; 
11.             }); 
12.         } 
13.     }); 
14. }*/  

 经过与线程池的配合，dispatch queue分为下面两种：而系统默认就有一个串行队列main_queue和并行队列global_queue：

•      Serial Dispatch Queue -- 线程池只提供一个线程用来执行任务，因此后一个任务必须等到前一个任务执行结束才能开始。
•      Concurrent Dispatch Queue -- 线程池提供多个线程来执行任务，因此能够按序启动多个任务并发执行。

而系统默认就有一个串行队列main_queue和并行队列global_queue：

[cpp] view plain copy

1. dispatch_queue_t globalQ = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);  
2. dispatch_queue_t mainQ = dispatch_get_main_queue();  

一般，咱们能够在global_queue中作一些long-running的任务，完成后在main_queue中更新UI，避免UI阻塞，没法响应用户操做：

[cpp] view plain copy

1. dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{  
2.         // long-running task  
3.         dispatch_async(dispatch_get_main_queue(), ^{  
4.             // update UI  
5.         });  
6.     });  

1.Serial quque(private dispatch queue)

　　每次运行一个任务,能够添加多个,执行次序FIFO. 一般是指程序员生成的,好比:

NSDate *da = [NSDate date];
NSString *daStr = [da description]; const char *queueName = [daStr UTF8String];
dispatch_queue_t myQueue = dispatch_queue_create(queueName, DISPATCH_QUEUE_PRIORITY_DEFAULT);

下面仍是下载图片例子：

[cpp] view plain copy

1. - (IBAction)touchUpInsideByThreadOne:(id)sender {  
2.     NSDate *da = [NSDate date];  
3.     NSString *daStr = [da description];  
4.     const char *queueName = [daStr UTF8String];  
5.     dispatch_queue_t myQueue = dispatch_queue_create(queueName, NULL);  
6.       
7.     dispatch_async(myQueue, ^{  
8.         NSURL * url = [NSURL URLWithString:@"http://avatar.csdn.net/2/C/D/1_totogo2010.jpg"];  
9.         NSData * data = [[NSData alloc]initWithContentsOfURL:url];  
10.         UIImage *image = [[UIImage alloc]initWithData:data];  
11.         if (data != nil) {  
12.             dispatch_async(dispatch_get_main_queue(), ^{  
13.                 self.imageView.image = image;  
14.             });  
15.         }  
16.     });  
17.       
18.     dispatch_release(myQueue);  
19. }  

为了验证Serial queue的FIFO特性，写了以下的验证代码：发现的确是顺序执行的。

[cpp] view plain copy

1. - (IBAction)touchUpInsideByThreadOne:(id)sender {  
2.     NSDate *da = [NSDate date];  
3.     NSString *daStr = [da description];  
4.     const char *queueName = [daStr UTF8String];  
5.     dispatch_queue_t myQueue = dispatch_queue_create(queueName, DISPATCH_QUEUE_SERIAL);  
6.       
7.     dispatch_async(myQueue, ^{  
8.         [NSThread sleepForTimeInterval:6];  
9.         NSLog(@"[NSThread sleepForTimeInterval:6];");  
10.     });  
11.       
12.     dispatch_async(myQueue, ^{  
13.         [NSThread sleepForTimeInterval:3];  
14.         NSLog(@"[NSThread sleepForTimeInterval:3];");  
15.     });  
16.       
17.     dispatch_async(myQueue, ^{  
18.         [NSThread sleepForTimeInterval:1];  
19.         NSLog(@"[NSThread sleepForTimeInterval:1];");  
20.     });  
21.       
22.     dispatch_release(myQueue);  
23. }  

运行结果为：

[cpp] view plain copy

1. 2013-07-24 16:37:14.397 NSThreadAndBlockDemo[1924:12303] [NSThread sleepForTimeInterval:6];  
2. 2013-07-24 16:37:17.399 NSThreadAndBlockDemo[1924:12303] [NSThread sleepForTimeInterval:3];  
3. 2013-07-24 16:37:18.401 NSThreadAndBlockDemo[1924:12303] [NSThread sleepForTimeInterval:1];  

3. Concurrent queue(global dispatch queue):

能够同时运行多个任务,每一个任务的启动时间是按照加入queue的顺序,结束的顺序依赖各自的任务.使用dispatch_get_global_queue得到.

[cpp] view plain copy

1. - (IBAction)touchUpInsideByThreadOne:(id)sender {  
2.     dispatch_queue_t myQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);  
3.       
4.     dispatch_async(myQueue, ^{  
5.         [NSThread sleepForTimeInterval:6];  
6.         NSLog(@"[NSThread sleepForTimeInterval:6];");  
7.     });  
8.       
9.     dispatch_async(myQueue, ^{  
10.         [NSThread sleepForTimeInterval:3];  
11.         NSLog(@"[NSThread sleepForTimeInterval:3];");  
12.     });  
13.       
14.     dispatch_async(myQueue, ^{  
15.         [NSThread sleepForTimeInterval:1];  
16.         NSLog(@"[NSThread sleepForTimeInterval:1];");  
17.     });  
18.       
19.     dispatch_release(myQueue);  
20. }  

运行的结果为：

[cpp] view plain copy

1. 2013-07-24 16:38:41.660 NSThreadAndBlockDemo[1944:12e03] [NSThread sleepForTimeInterval:1];  
2. 2013-07-24 16:38:43.660 NSThreadAndBlockDemo[1944:12b03] [NSThread sleepForTimeInterval:3];  
3. 2013-07-24 16:38:46.660 NSThreadAndBlockDemo[1944:12303] [NSThread sleepForTimeInterval:6];  

2、dispatch_group_async的使用

dispatch_group_async能够实现监听一组任务是否完成，完成后获得通知执行其余的操做。这个方法颇有用，好比你执行三个下载任务，当三个任务都下载完成后你才通知界面说完成的了。下面是一段例子代码：

[cpp] view plain copy

1. - (IBAction)touchUpInsideByThreadOne:(id)sender {  
2.     dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);  
3.     dispatch_group_t group = dispatch_group_create();  
4.     dispatch_group_async(group, queue, ^{  
5.         [NSThread sleepForTimeInterval:6];  
6.         NSLog(@"group1 [NSThread sleepForTimeInterval:6];");  
7.     });  
8.     dispatch_group_async(group, queue, ^{  
9.         [NSThread sleepForTimeInterval:3];  
10.         NSLog(@"group2 [NSThread sleepForTimeInterval:3];");  
11.     });  
12.     dispatch_group_async(group, queue, ^{  
13.         [NSThread sleepForTimeInterval:1];  
14.         NSLog(@"group3 [NSThread sleepForTimeInterval:1];");  
15.     });  
16.     dispatch_group_notify(group, dispatch_get_main_queue(), ^{  
17.         NSLog(@"main thread.");  
18.     });  
19.     dispatch_release(group);  
20. }  

执行结果为：

[cpp] view plain copy

1. 2013-07-24 16:48:23.063 NSThreadAndBlockDemo[2004:12e03] group3 [NSThread sleepForTimeInterval:1];  
2. 2013-07-24 16:48:25.063 NSThreadAndBlockDemo[2004:12b03] group2 [NSThread sleepForTimeInterval:3];  
3. 2013-07-24 16:48:28.063 NSThreadAndBlockDemo[2004:12303] group1 [NSThread sleepForTimeInterval:6];  
4. 2013-07-24 16:48:28.065 NSThreadAndBlockDemo[2004:11303] main thread.  

果真， dispatch_group_async只会监听最终的结果完成后，并通知main queue，那若是是咱们须要顺序执行的话呢？请看下面的dispatch_barrier_async。

三、dispatch_barrier_async的使用

dispatch_barrier_async是在前面的任务执行结束后它才执行，并且它后面的任务等它执行完成以后才会执行

例子代码以下：

[cpp] view plain copy

1. - (IBAction)touchUpInsideByThreadOne:(id)sender {  
2.     dispatch_queue_t queue = dispatch_queue_create("gcdtest.rongfzh.yc", DISPATCH_QUEUE_CONCURRENT);  
3.       
4.     dispatch_async(queue, ^{  
5.         [NSThread sleepForTimeInterval:3];  
6.         NSLog(@"dispatch_async1");  
7.     });  
8.     dispatch_async(queue, ^{  
9.         [NSThread sleepForTimeInterval:1];  
10.         NSLog(@"dispatch_async2");  
11.     });  
12.     dispatch_barrier_async(queue, ^{  
13.         NSLog(@"dispatch_barrier_async");  
14.         [NSThread sleepForTimeInterval:0.5];  
15.           
16.     });  
17.     dispatch_async(queue, ^{  
18.         [NSThread sleepForTimeInterval:1];  
19.         NSLog(@"dispatch_async3");  
20.     });  
21. }  

执行结果为：

[cpp] view plain copy

1. 2013-07-24 17:01:54.580 NSThreadAndBlockDemo[2153:12b03] dispatch_async2  
2. 2013-07-24 17:01:56.580 NSThreadAndBlockDemo[2153:12303] dispatch_async1  
3. 2013-07-24 17:01:56.580 NSThreadAndBlockDemo[2153:12303] dispatch_barrier_async  
4. 2013-07-24 17:01:58.083 NSThreadAndBlockDemo[2153:12303] dispatch_async3  

若是使用dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);会发现运行结果为：

[cpp] view plain copy

1. 2013-07-24 17:07:17.577 NSThreadAndBlockDemo[2247:12e03] dispatch_barrier_async  
2. 2013-07-24 17:07:18.579 NSThreadAndBlockDemo[2247:15207] dispatch_async3  
3. 2013-07-24 17:07:19.578 NSThreadAndBlockDemo[2247:12b03] dispatch_async2  
4. 2013-07-24 17:07:20.577 NSThreadAndBlockDemo[2247:12303] dispatch_async1  

说明dispatch_barrier_async的顺序执行仍是依赖queue的类型啊，必须要queue的类型为 dispatch_queue_create建立的，并且attr参数值必需是DISPATCH_QUEUE_CONCURRENT类型，前面两个非 dispatch_barrier_async的类型的执行是依赖其自己的执行时间的，若是attr若是是DISPATCH_QUEUE_SERIAL 时，那就彻底是符合Serial queue的FIFO特征了。

四、dispatch_apply

执行某个代码片断N次。

dispatch_apply(5, globalQ, ^(size_t index) {

// 执行5次

});

五、dispatch_once

     dispatch_once这个函数，它能够保证整个应用程序生命周期中某段代码只被执行一次！

[cpp] view plain copy

1. static dispatch_once_t onceToken;  
2.     dispatch_once(&onceToken, ^{  
3.         // code to be executed once  
4.     });  

六、dispatch_after

有时候咱们须要等个几秒钟而后作个动画或者给个提示，这时候能够用dispatch_after这个函数：

[cpp] view plain copy

1. double delayInSeconds = 2.0;  
2.     dispatch_time_t popTime = dispatch_time(DISPATCH_TIME_NOW, delayInSeconds * NSEC_PER_SEC);  
3.     dispatch_after(popTime, dispatch_get_main_queue(), ^(void){  
4.         // code to be executed on the main queue after delay  
5.     });  

七、dispatch_set_target_queue

经过 dispatch_set_target_queue 函数能够设置一个dispatch queue的优先级，或者指定一个dispatch source相应的事件处理提交到哪一个queue上。

[cpp] view plain copy

1. dispatch_set_target_queue(serialQ, globalQ);  

因而可知,GCD的使用很是简单,以个人使用经验来看,之后会逐步淘汰使用NSOperation而改用GCD.