1.基本介紹:
(1) Grand Central Dispatch (GCD)是Apple開發的一個多核程式設計的較新的解決方法。在Mac OS X 10.6雪豹中首次推出,并在最近引入到了iOS4.0。
(2) GCD是一個替代諸如NSThread等技術的很高效和強大的技術。GCD完全可以處理諸如資料鎖定和資源洩漏等複雜的異步程式設計問題。
(3) 它是IOS多線程抽象層次最高的一層,下面還有前面2章節介紹的更加輕量級的Cocoa operations,和Thread。
2.主要方法:
(1)建立一個隊列
dispatch_queue_t queue = dispatch_queue_create("LoadImage", NULL);
其中,第一個參數是辨別隊列的,第二個參數是用來定義隊列的參數(目前不支援,是以傳入NULL)。
(2)執行一個隊列(async--->異步,sync--->同步)
dispatch_async(queue, ^{ [self doSomething]; });
其中,首先傳入之前建立的隊列,然後提供由隊列運作的代碼塊。
(3)聲明并執行一個隊列 (如果不需要保留要運作的隊列的引用)
dispatch_async(dispatch_queue_create ("LoadImage", NULL), ^{ [self doSomething]; });
(4)暫停一個隊列
dispatch_suspend(queue);
(5)恢複一個隊列(如果暫停一個隊列不要忘記恢複)
dispatch_resume(queue);
(6)将代碼塊中的工作轉回到主線程(注意,dispatch_suspend (以及dispatch_resume)在主線程上不起作用)
dispatch_sync(dispatch_get_main_queue(), ^{ [self dismissLoginWindow]; });
3.代碼示例
#pragma mark - GCD(Grand Central Dispatch)
- (void)GCD{
dispatch_queue_t queue = dispatch_queue_create("test", NULL);
// 多一個a,異步
dispatch_async(queue, ^{
for (int i = 0; i < 100; i++) {
NSLog(@"--多線程--%d",i);
}
// 判斷是否是在多線程運作環境
BOOL isMulti = [NSThread isMultiThreaded];
NSLog(@"%d",isMulti);
if (isMulti) {
NSLog(@"*********多線程***********");
}
// 将代碼塊中的工作轉回到主線程
dispatch_sync(dispatch_get_main_queue(), ^{
// 判斷是否是在主線程運作環境
BOOL isMain = [NSThread isMainThread];
if (isMain) {
NSLog(@"*********主線程**********");
}
});
});
/* // 通過此方式,還是運作在目前線程
dispatch_sync(queue, ^{
// 主線程
});
*/
for (int i = 0; i < 100; i++) {
NSLog(@"--主線程--%d",i);
}
}
4.加載網絡圖檔(在多線程加載明顯比放在主線程加載快N多)
#pragma mark - 給UIImageView寫一個類目
@interface UIImageView (WebCach)
- (void)setImageWithURL:(NSURL *)url;
@end
#import "UIImageView+WebCach.h"
@implementation UIImageView (WebCach)
- (void)setImageWithURL:(NSURL *)url{
dispatch_queue_t queue = dispatch_queue_create("loadImage", NULL);
dispatch_async(queue, ^{
NSData * data = [NSData dataWithContentsOfURL:url];
UIImage * image = [UIImage imageWithData:data];
// 加載UI的操作,一般放在主線程進行
dispatch_async(dispatch_get_main_queue(), ^{
self.image = image;
});
});
}
@end
- (void)viewDidLoad
{
[super viewDidLoad];
// Do any additional setup after loading the view.
UIImageView * imageView = [[UIImageView alloc]initWithFrame:CGRectMake(100, 100, 100, 100)];
[imageView setImageWithURL:[NSURL URLWithString:@"http://www.baidu.com/img/bdlogo.gif"]];
[self.view addSubview:imageView];
}
5.最後,引用别人部落格對幾個方法的介紹
@dispatch對象
原文位址 http://www.cnblogs.com/sunfrog/p/3243230.html
談起iOS的dispatch(正式稱謂是Grand Central Dispatch或GCD),不得不說這又是iOS(包括MacOSX)平台的創新,優缺點這裡不讨論,隻有當你使用時才能真正體會到。我們說dispatch函數的主要目的是實作多任務并發代碼,那麼要了解dispatch函數,先來了解dispatch對象的定義。
dispatch對象類型的部分定義,主要使用C語言的宏定義:
<os/object.h>檔案:
#define OS_OBJECT_CLASS(name) OS_##name
#define OS_OBJECT_DECL(name, ...) \
@protocol OS_OBJECT_CLASS(name) __VA_ARGS__ \
@end \
typedef NSObject<OS_OBJECT_CLASS(name)> *name##_t
#define OS_OBJECT_DECL_SUBCLASS(name, super) \
OS_OBJECT_DECL(name, <OS_OBJECT_CLASS(super)>)
<dispatch/object.h>檔案:
#define DISPATCH_DECL(name) OS_OBJECT_DECL_SUBCLASS(name, dispatch_object)
#define DISPATCH_GLOBAL_OBJECT(type, object) ((OS_OBJECT_BRIDGE type)&(object))
OS_OBJECT_DECL(dispatch_object); //定義dispatch_object_t
<dispatch/queue.h>檔案(dispatch隊列類定義,其它dispatch對象類似):
DISPATCH_DECL(dispatch_queue); //定義dispatch_queue_t
可以通過Xcode預編譯後可以看到最終結果,最終定義的都是NSObject類,雖然它們之間沒用直接繼承關系,但都實作OS_dispatch_object接口,這樣dispatch_queue_t對象也同樣是dispatch_object_t的對象了。下面就是預編譯dispatch_object_t和dispatch_queue_t的結果:
@protocol OS_dispatch_object
@end
typedef NSObject<OS_dispatch_object> *dispatch_object_t;
@protocol OS_dispatch_queue <OS_dispatch_object>
@end
typedef NSObject<OS_dispatch_queue> *dispatch_queue_t;
由于dispatch api接口定義成C函數的形式,dispatch的對象都是由C函數形式的廠方法得到(不能繼承dispatch類,不用alloc),這樣做隐藏dispatch對象的具體形态,把注意力放在如何調用dispatch api上。
從上面dispatch對象宏定義可以看到dispatch對象類的名稱一般為dispatch_xyz_t(嚴格來講是對象指針),它們都可以看成dispatch_object_t的子類(對象指針),是以使用dispatch對象時套用這個概念就行。
有關dispatch對象的基本接口如下:
void dispatch_retain(dispatch_object_t object); //替代dispatch對象正常的retain來持有對象,但ARC程式設計中不再允許
void dispatch_release(dispatch_object_t object); //替代dispatch對象正常的release來釋放對象,同樣ARC程式設計中不再允許
void dispatch_set_context(dispatch_object_t object, void *context); //給dispatch對象綁定特定資料對象(類似線程的TLS資料),會被傳給dispatch對象的finalizer函數
void *dispatch_get_context(dispatch_object_t object); //傳回dispatch對象綁定的資料對象指針
void dispatch_set_finalizer_f(dispatch_object_t object, dispatch_function_t finalizer); //設定dispatch對象的finalizer函數,當該對象釋放時會調用finalizer,部分代碼解釋如何使用這個函數(ARC模式):
dispatch_object_t dispatchObject = ...;
void *context = ...;
dispatch_set_context(dispatchObject, context);
dispatch_set_finalizer_f(dispatchObject, finalizer);
......
dispatchObject = nil; //dispatchObject被釋放,這時調用finalizer函數
......
void finalizer(void *context)
{
//處理或釋放context相關資源
}
dispatch對象的另外兩個接口是:
void dispatch_resume(dispatch_object_t object); //激活(啟動)在dispatch對象上的block調用,可以運作多個block
void dispatch_suspend(dispatch_object_t object); //挂起(暫停)在dispatch對象上的block調用,已經運作的block不會停止
一般這兩個函數的調用必須成對,否則運作會出現異常。
至此你是否發現這兩個函數有些與衆不同呢?好像從來沒有這麼使用對象的,啟動對象--暫停對象,呵呵。這正是了解dispatch對象的關鍵所在。dispatch對象其實是抽象的任務,把動态的任務變成對象來管理。任務是動态的,不存在繼承關系,這就是為什麼GCD沒有提供靜态繼承dispatch對象類的方式。如果能這樣了解,那麼在使用dispatch函數時就能夠更靈活地去編寫代碼,實作各種并發的多任務代碼。
@dispatch隊列
GCD程式設計的核心就是dispatch隊列,dispatch block的執行最終都會放進某個隊列中去進行,它類似NSOperationQueue但更複雜也更強大,并且可以嵌套使用。是以說,結合block實作的GCD,把函數閉包(Closure)的特性發揮得淋漓盡緻。
dispatch隊列的生成可以有這幾種方式:
1. dispatch_queue_t queue = dispatch_queue_create("com.dispatch.serial", DISPATCH_QUEUE_SERIAL); //生成一個串行隊列,隊列中的block按照先進先出(FIFO)的順序去執行,實際上為單線程執行。第一個參數是隊列的名稱,在調試程式時會非常有用,所有盡量不要重名了。
2. dispatch_queue_t queue = dispatch_queue_create("com.dispatch.concurrent", DISPATCH_QUEUE_CONCURRENT); //生成一個并發執行隊列,block被分發到多個線程去執行
3. dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0); //獲得程式程序預設産生的并發隊列,可設定優先級來選擇高、中、低三個優先級隊列。由于是系統預設生成的,是以無法調用dispatch_resume()和dispatch_suspend()來控制執行繼續或中斷。需要注意的是,三個隊列不代表三個線程,可能會有更多的線程。并發隊列可以根據實際情況來自動産生合理的線程數,也可了解為dispatch隊列實作了一個線程池的管理,對于程式邏輯是透明的。
官網文檔解釋說共有三個并發隊列,但實際還有一個更低優先級的隊列,設定優先級為DISPATCH_QUEUE_PRIORITY_BACKGROUND。Xcode調試時可以觀察到正在使用的各個dispatch隊列。
4. dispatch_queue_t queue = dispatch_get_main_queue(); //獲得主線程的dispatch隊列,實際是一個串行隊列。同樣無法控制主線程dispatch隊列的執行繼續或中斷。
接下來我們可以使用dispatch_async或dispatch_sync函數來加載需要運作的block。
dispatch_async(queue, ^{
//block具體代碼
}); //異步執行block,函數立即傳回
dispatch_sync(queue, ^{
//block具體代碼
}); //同步執行block,函數不傳回,一直等到block執行完畢。編譯器會根據實際情況優化代碼,是以有時候你會發現block其實還在目前線程上執行,并沒用産生新線程。
實際程式設計經驗告訴我們,盡可能避免使用dispatch_sync,嵌套使用時還容易引起程式死鎖。
如果queue1是一個串行隊列的話,這段代碼立即産生死鎖:
dispatch_sync(queue1, ^{
dispatch_sync(queue1, ^{
......
});
......
});
不妨思考下,為什麼下面代碼也肯定死鎖:
dispatch_sync(dispatch_get_main_queue(), ^{
......
});
那實際運用中,一般可以用dispatch這樣來寫,常見的網絡請求資料多線程執行模型:
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
//子線程中開始網絡請求資料
//更新資料模型
dispatch_sync(dispatch_get_main_queue(), ^{
//在主線程中更新UI代碼
});
});
程式的背景運作和UI更新代碼緊湊,代碼邏輯一目了然。
dispatch隊列是線程安全的,可以利用串行隊列實作鎖的功能。比如多線程寫同一資料庫,需要保持寫入的順序和每次寫入的完整性,簡單地利用串行隊列即可實作:
dispatch_queue_t queue1 = dispatch_queue_create("com.dispatch.writedb", DISPATCH_QUEUE_SERIAL);
- (void)writeDB:(NSData *)data
{
dispatch_async(queue1, ^{
//write database
});
}
下一次調用writeDB:必須等到上次調用完成後才能進行,保證writeDB:方法是線程安全的。
dispatch隊列還實作其它一些常用函數,包括:
void dispatch_apply(size_t iterations, dispatch_queue_t queue, void (^block)(size_t)); //重複執行block,需要注意的是這個方法是同步傳回,也就是說等到所有block執行完畢才傳回,如需異步傳回則嵌套在dispatch_async中來使用。多個block的運作是否并發或串行執行也依賴queue的是否并發或串行。
void dispatch_barrier_async(dispatch_queue_t queue, dispatch_block_t block); //這個函數可以設定同步執行的block,它會等到在它加入隊列之前的block執行完畢後,才開始執行。在它之後加入隊列的block,則等到這個block執行完畢後才開始執行。
void dispatch_barrier_sync(dispatch_queue_t queue, dispatch_block_t block); //同上,除了它是同步傳回函數
void dispatch_after(dispatch_time_t when, dispatch_queue_t queue, dispatch_block_t block); //延遲執行block
最後再來看看dispatch隊列的一個很有特色的函數:
void dispatch_set_target_queue(dispatch_object_t object, dispatch_queue_t queue);
它會把需要執行的任務對象指定到不同的隊列中去處理,這個任務對象可以是dispatch隊列,也可以是dispatch源(以後博文會介紹)。而且這個過程可以是動态的,可以實作隊列的動态排程管理等等。比如說有兩個隊列dispatchA和dispatchB,這時把dispatchA指派到dispatchB:
dispatch_set_target_queue(dispatchA, dispatchB);
那麼dispatchA上還未運作的block會在dispatchB上運作。這時如果暫停dispatchA運作:
dispatch_suspend(dispatchA);
則隻會暫停dispatchA上原來的block的執行,dispatchB的block則不受影響。而如果暫停dispatchB的運作,則會暫停dispatchA的運作。
這裡隻簡單舉個例子,說明dispatch隊列運作的靈活性,在實際應用中你會逐漸發掘出它的潛力。
dispatch隊列不支援cancel(取消),沒有實作dispatch_cancel()函數,不像NSOperationQueue,不得不說這是個小小的缺憾。
@dispatch源
原文位址 http://www.cnblogs.com/sunfrog/p/3243230.html
dispatch源(dispatch source)和RunLoop源概念上有些類似的地方,而且使用起來更簡單。要很好地了解dispatch源,其實把它看成一種特别的生産消費模式。dispatch源好比生産的資料,當有新資料時,會自動在dispatch指定的隊列(即消費隊列)上運作相應地block,生産和消費同步是dispatch源會自動管理的。
dispatch源的使用基本為以下步驟:
1. dispatch_source_t source = dispatch_source_create(dispatch_source_type, handler, mask, dispatch_queue); //建立dispatch源,這裡使用加法來合并dispatch源資料,最後一個參數是指定dispatch隊列
2. dispatch_source_set_event_handler(source, ^{ //設定響應dispatch源事件的block,在dispatch源指定的隊列上運作
//可以通過dispatch_source_get_data(source)來得到dispatch源資料
});
3. dispatch_resume(source); //dispatch源建立後處于suspend狀态,是以需要啟動dispatch源
4. dispatch_source_merge_data(source, value); //合并dispatch源資料,在dispatch源的block中,dispatch_source_get_data(source)就會得到value。
是不是很簡單?而且完全不必編寫同步的代碼。比如網絡請求資料的模式,就可以這樣來寫:
dispatch_source_t source = dispatch_source_create(DISPATCH_SOURCE_TYPE_DATA_ADD, 0, 0, dispatch_get_global_queue(0, 0));
dispatch_source_set_event_handler(source, ^{
dispatch_sync(dispatch_get_main_queue(), ^{
//更新UI
});
});
dispatch_resume(source);
dispatch_async(dispatch_get_global_queue(0, 0), ^{
//網絡請求
dispatch_source_merge_data(source, 1); //通知隊列
});
dispatch源還支援其它一些系統源,包括定時器、監控檔案的讀寫、監控檔案系統、監控信号或程序等,基本上調用的方式原理和上面相同,隻是有可能是系統自動觸發事件。比如dispatch定時器:
dispatch_source_t timer = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, queue);
dispatch_source_set_timer(timer, dispatch_walltime(NULL, 0), 10*NSEC_PER_SEC, 1*NSEC_PER_SEC); //每10秒觸發timer,誤差1秒
dispatch_source_set_event_handler(timer, ^{
//定時處理
});
dispatch_resume(timer);
其它情況的dispatch源就不再一一舉例,可參看官網有具體文檔: https://developer.apple.com/library/ios/documentation/General/Conceptual/ConcurrencyProgrammingGuide/GCDWorkQueues/GCDWorkQueues.html#//apple_ref/doc/uid/TP40008091-CH103-SW1
最後,dispatch源的其它一些函數大緻羅列如下:
uintptr_t dispatch_source_get_handle(dispatch_source_t source); //得到dispatch源建立,即調用dispatch_source_create的第二個參數
unsignedlong dispatch_source_get_mask(dispatch_source_t source); //得到dispatch源建立,即調用dispatch_source_create的第三個參數
void dispatch_source_cancel(dispatch_source_t source); //取消dispatch源的事件處理--即不再調用block。如果調用dispatch_suspend隻是暫停dispatch源。
long dispatch_source_testcancel(dispatch_source_t source); //檢測是否dispatch源被取消,如果傳回非0值則表明dispatch源已經被取消
void dispatch_source_set_cancel_handler(dispatch_source_t source, dispatch_block_t cancel_handler); //dispatch源取消時調用的block,一般用于關閉檔案或socket等,釋放相關資源
void dispatch_source_set_registration_handler(dispatch_source_t source, dispatch_block_t registration_handler); //可用于設定dispatch源啟動時調用block,調用完成後即釋放這個block。也可在dispatch源運作當中随時調用這個函數。
@dispatch同步
原文位址 http://www.cnblogs.com/sunfrog/p/3243230.html
GCD提供兩種方式支援dispatch隊列同步,即dispatch組和信号量。
一、dispatch組(dispatch group)
1. 建立dispatch組
dispatch_group_t group = dispatch_group_create();
2. 啟動dispatch隊列中的block關聯到group中
dispatch_group_async(group, queue, ^{
// 。。。
});
3. 等待group關聯的block執行完畢,也可以設定逾時參數
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
4. 為group設定通知一個block,當group關聯的block執行完畢後,就調用這個block。類似dispatch_barrier_async。
dispatch_group_notify(group, queue, ^{
// 。。。
});
5. 手動管理group關聯的block的運作狀态(或計數),進入和退出group次數必須比對
dispatch_group_enter(group);
dispatch_group_leave(group);
是以下面的兩種調用其實是等價的,
A)
dispatch_group_async(group, queue, ^{
// 。。。
});
B)
dispatch_group_enter(group);
dispatch_async(queue, ^{
//。。。
dispatch_group_leave(group);
});
是以,可以利用dispatch_group_enter、 dispatch_group_leave和dispatch_group_wait來實作同步,具體例子:http://stackoverflow.com/questions/10643797/wait-until-multiple-operations-executed-including-completion-block-afnetworki/10644282#10644282。
二、dispatch信号量(dispatch semaphore)
1. 建立信号量,可以設定信号量的資源數。0表示沒有資源,調用dispatch_semaphore_wait會立即等待。
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
2. 等待信号,可以設定逾時參數。該函數傳回0表示得到通知,非0表示逾時。
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
3. 通知信号,如果等待線程被喚醒則傳回非0,否則傳回0。
dispatch_semaphore_signal(semaphore);
最後,還是回到生成消費者的例子,使用dispatch信号量是如何實作同步:
dispatch_semaphore_t sem = dispatch_semaphore_create(0);
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{ //消費者隊列
while (condition) {
if (dispatch_semaphore_wait(sem, dispatch_time(DISPATCH_TIME_NOW, 10*NSEC_PER_SEC))) //等待10秒
continue;
//得到資料
}
});
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{ //生産者隊列
while (condition) {
if (!dispatch_semaphore_signal(sem))
{
sleep(1); //wait for a while
continue;
}
//通知成功
}
});