文档章节

GCD之dispatch queue深入浅出

Famiove
 Famiove
发布于 2015/09/03 15:50
字数 1722
阅读 12
收藏 0

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程序员.

一、下面首先来看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 plaincopy

  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 plaincopy

  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 plaincopy

  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 plaincopy

  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 plaincopy

  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 plaincopy

  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 plaincopy

  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 plaincopy

  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];  


二、dispatch_group_async的使用

dispatch_group_async可以实现监听一组任务是否完成,完成后得到通知执行其他的操作。这个方法很有用,比如你执行三个下载任务,当三个任务都下载完成后你才通知界面说完成的了。下面是一段例子代码:

[cpp] view plaincopy

  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 plaincopy

  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。

3、dispatch_barrier_async的使用

dispatch_barrier_async是在前面的任务执行结束后它才执行,而且它后面的任务等它执行完成之后才会执行

例子代码如下:

[cpp] view plaincopy

  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 plaincopy

  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 plaincopy

  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特征了。


4、dispatch_apply

执行某个代码片段N次。

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

// 执行5次

});

5、dispatch_once

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

[cpp] view plaincopy

  1. static dispatch_once_t onceToken;  

  2.     dispatch_once(&onceToken, ^{  

  3.         // code to be executed once  

  4.     });  

6、dispatch_after

有时候我们需要等个几秒钟然后做个动画或者给个提示,这时候可以用dispatch_after这个函数:

[cpp] view plaincopy

  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.     });  

7、dispatch_set_target_queue

通过dispatch_set_target_queue函数可以设置一个dispatch queue的优先级,或者指定一个dispatch source相应的事件处理提交到哪个queue上。

[cpp] view plaincopy

  1. dispatch_set_target_queue(serialQ, globalQ);  


由此可见,GCD的使用非常简单,以我的使用经验来看,以后会逐步淘汰使用NSOperation而改用GCD.


本文转载自:http://blog.csdn.net/samuelltk/article/details/9452203

Famiove
粉丝 0
博文 5
码字总数 424
作品 0
崇明
私信 提问
Effective Objective-C Notes:GCD 实现同步锁

本文名为《GCD 实现同步锁》,内容不止于锁。文章试图通过 GCD 同步锁的问题,尽量往外延伸扩展,以讲解更多 GCD 同步机制的内容。 引语:线程安全问题 如果一段代码所在的进程中有多个线程在...

goodlook
2016/04/04
50
0
iOS 多线程GCD

一.简介 GCD (Grand Central Dispatch)是Apple开发的多核编程的解决方法。 二.优点 1.GCD可用于多核的并行运算 2.GCD自动利用更多CPU内核(双核,四核) 3.GCD自动管理线程的生命周期(创建线...

龙飞凤舞de心
2018/02/23
13
0
多线程—GCD介绍

阅读原文请点击:file:///Users/feifanit/Downloads/iOS开发多线程篇—GCD介绍%20-%20文顶顶%20-%20博客园.html 一、简单介绍 1.什么是GCD? 全称是Grand Central Dispatch,可译为“牛逼的中...

细雨微风轻诉流年
2016/09/07
3
0
关于GCD一些事

1.GCD简单介绍   GCD全称为"Grand Central Dispath" 纯C语言,提供了非常强大的函数 2.GCD的好处   GCD是苹果为多核的并行运算提出的解决方案   GCD会自动利用更多的CPU内核   GCD会...

冰泪_
2016/08/31
13
0
GCD介绍(一): 基本概念和Dispatch Queue

什么是GCD? Grand Central Dispatch或者GCD,是一套低层API,提供了一种新的方法来进行并发程序编写。从基本功能上讲,GCD有点像NSOperationQueue,他们都允许程序将任务切分为多个单一任务...

于赟
2012/11/04
247
0

没有更多内容

加载失败,请刷新页面

加载更多

Executor线程池原理与源码解读

线程池为线程生命周期的开销和资源不足问题提供了解决方 案。通过对多个任务重用线程,线程创建的开销被分摊到了多个任务上。 线程实现方式 Thread、Runnable、Callable //实现Runnable接口的...

小强的进阶之路
47分钟前
5
0
maven 环境隔离

解决问题 即 在 resource 文件夹下面 ,新增对应的资源配置文件夹,对应 开发,测试,生产的不同的配置内容 <resources> <resource> <directory>src/main/resources.${deplo......

之渊
今天
8
0
详解箭头函数和普通函数的区别以及箭头函数的注意事项、不适用场景

箭头函数是ES6的API,相信很多人都知道,因为其语法上相对于普通函数更简洁,深受大家的喜爱。就是这种我们日常开发中一直在使用的API,大部分同学却对它的了解程度还是不够深... 普通函数和...

OBKoro1
今天
7
0
轻量级 HTTP(s) 代理 TinyProxy

CentOS 下安装 TinyProxy yum install -y tinyproxy 启动、停止、重启 # 启动service tinyproxy start# 停止service tinyproxy stop# 重启service tinyproxy restart 相关配置 默认...

Anoyi
今天
2
0
Linux创建yum仓库

第一步、搞定自己的光盘 #创建文件夹 mkdir -p /media/cdrom #挂载光盘 mount /dev/cdrom /media/cdrom #编辑配置文件使其永久生效 vim /etc/fstab 第二步,编辑yun源 vim /ect yum.repos.d...

究极小怪兽zzz
今天
6
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部