Dispatch Queue:
開發(fā)者將需要執(zhí)行的任務添加到合適的Dispatch Queue中即可闹获,Dispatch Queue會根據(jù)任務添加的順序先到先執(zhí)行,其中有以下幾種隊列:
1.main dispatch queue
功能跟主線程一樣河哑,通過dispatch_get_main_queue()來獲取避诽,提交到main queue的任務實際上都是在主線程執(zhí)行的,所以這是一個串行隊列
2.global dispatch queues
系統(tǒng)給每個應用提供四個全局的并發(fā)隊列璃谨,這四個隊列分別有不同的優(yōu)先級:高沙庐、默認鲤妥、低以及后臺,用戶不能去創(chuàng)建全局隊列拱雏,只能根據(jù)優(yōu)先級去獲让薨病:
dispatch_queue_t queue;
queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
3.user create queue
用戶可以通過dispatch_queue_create自己創(chuàng)建隊列,該函數(shù)有兩個參數(shù)铸抑,第一個是隊列的名稱贡耽,在debug的時候方便區(qū)分;第二個是隊列的一些屬性鹊汛,NULL或者DISPATCH_QUEUE_SERIAL創(chuàng)建出來的隊列事串行隊列蒲赂,如果傳遞DISPATCH_QUEUE_CONCURRENT則為并行隊列。
// 創(chuàng)建并行隊列
dispatch_queue_t queue;
queue=dispatch_queue_create(“com.example.MyQueue”, DISPATCH_QUEUE_CONCURRENT);
4.隊列優(yōu)先級
dispatch_queue_create創(chuàng)建隊列的優(yōu)先級跟global dispatch queue的默認優(yōu)先級一樣柒昏,假如我們需要設置隊列的優(yōu)先級凳宙,可以通過dispatch_queue_attr_make_with_qos_class或者dispatch_set_target_queue方法熙揍;
Quality of Service 枚舉來使用user interactive职祷,user initiated,utility和bakground
通過這些告訴系統(tǒng)我們在進行什么樣的工作届囚,然后系統(tǒng)會通過合理的資源控制來最高效的執(zhí)行任務代碼有梆,其中主要涉及到CPU調度的優(yōu)先級、IO優(yōu)先級意系、任務運行在哪個線程以及運行的順序等等泥耀,我們通過一個抽象的Quality of Service 參數(shù)來表明任務的意圖以及類別。
一個典型的例子就是數(shù)據(jù)的讀寫蛔添,通常為了防止文件讀寫導致沖突痰催,我們會創(chuàng)建一個串行的隊列,所有的文件操作都是通過這個隊列來執(zhí)行迎瞧,比如FMDB夸溶,這樣就可以避免讀寫沖突。不過其實這樣是有提升空間的凶硅,當沒有更新數(shù)據(jù)時缝裁,讀操作其實是可以并行進行的,而寫操作需要串行執(zhí)行足绅。
Dispatch IO
當我們要讀取一份較大文件的時候捷绑,多個線程同時去讀肯定比一個線程去讀的速度要快,要實現(xiàn)這樣的功能可以通過dispatch io跟dispatch data來實現(xiàn)氢妈,通過dispatch io讀文件時粹污,會使用global dispatch queue將一個文件按照一個指定的分塊大小同時去讀區(qū)數(shù)據(jù),類似于:
dispatch_async(queue,^{/讀取0-99字節(jié)/});
dispatch_async(queue,^{/讀取100-199字節(jié)/});
dispatch_async(queue,^{/讀取200-299字節(jié)/});
…………
將文件分成一塊一塊并行讀取首量,讀取的數(shù)據(jù)通過Dispatch Data進行結合和分割壮吩。
dispatch_io_create函數(shù)生成Dispatch I/O,并指定發(fā)生error時用來執(zhí)行處理的block,以及執(zhí)行該block的Dispatch Queue粥航。
dispatch_io_set_low_water函數(shù)設置一次讀取的大小
dispatch_io_read函數(shù)使用Global Dispatch Queue開始并發(fā)讀取琅捏。每當各個分割的文件塊讀取結束時,會將含有文件塊數(shù)據(jù)的Dispatch Data(這里指pipedata)傳遞給dispatch_io_read函數(shù)指定的讀取結束時回調用的block递雀,這個block拿到每一塊讀取好的Dispatch Data(這里指的是pipe data)柄延,然后進行合并處理。
想提高文件讀取速度缀程,可以嘗試使用Dispatch I/O
Dispatch Source
Dispatch Source其實就是對kqueue功能的封裝搜吧,可以去查看dispatch_source的C源碼實現(xiàn)
kqueue是在XNU內核中發(fā)生各種事件時,在應用程序編程方執(zhí)行處理的技術杨凑,其CPU負荷非常小滤奈,盡量不占用資源。
kqueue可以說是應用程序處理XNU內核中發(fā)生的各種事件的方法中最優(yōu)秀的一種撩满。
Dispatch Source可處理以下事件
DISPATCH_SOURCE_TYPE_DATA_ADD 變量增加
DISPATCH_SOURCE_TYPE_DATA_OR 變量OR
DISPATCH_SOURCE_TYPE_MACH_SEND MACH端口發(fā)送
DISPATCH_SOURCE_TYPE_MACH_RECV MACH端口接收
DISPATCH_SOURCE_TYPE_PROC 檢測到與進程相關的事件
DISPATCH_SOURCE_TYPE_READ 可讀取文件映像
DISPATCH_SOURCE_TYPE_SIGNAL 接收信號
DISPATCH_SOURCE_TYPE_TIMER 定時器
DISPATCH_SOURCE_TYPE_VNODE 文件系統(tǒng)有變更
DISPATCH_SOURCE_TYPE_WRITE 可寫入文件映像
事件發(fā)生時蜒程,在指定的Dispatch Queue中可執(zhí)行事件的處理。
__block size_t total = 0;
size_t size = 要讀取的字節(jié)數(shù)
char buff = (char)malloc(size);
//設定為異步映像
fcntl(socked,F_SETFL,O_NONBLOCK);
//獲取用于追加事件處理的Global Dispatch Queue
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_PRIORITY_DEFAULT伺帘,0);
// 基于READ事件做成Dispatch Source
dispatch_source_t source = dispatch_source_create(DISPATCH_SOURCE_TYPE_READ, socked, 0, queue);
//指定發(fā)生READ事件時執(zhí)行的處理
dispatch_source_set_event_handle(source, ^{
//獲取可讀取的字節(jié)數(shù)
size_t available = dispatch_source_get_data(source);
// 從映像中讀取
int length = read(socked, buff, available);
// 發(fā)生錯誤時取消Dispatch Source
if ( length < 0){
// 錯誤處理
dispatch_source_cancel(source);
}
total += length;
if(total == size) {
// buff的處理
// 處理結束昭躺,取消Dispatch Source
dispatch_source_cancel(source);
}