Dispatch Queue:
開發(fā)者將需要執(zhí)行的任務(wù)添加到合適的Dispatch Queue中即可,Dispatch Queue會根據(jù)任務(wù)添加的順序先到先執(zhí)行,其中有以下幾種隊(duì)列:
1.main dispatch queue
功能跟主線程一樣,通過dispatch_get_main_queue()來獲取,提交到main queue的任務(wù)實(shí)際上都是在主線程執(zhí)行的,所以這是一個(gè)串行隊(duì)列
2.global dispatch queues
系統(tǒng)給每個(gè)應(yīng)用提供四個(gè)全局的并發(fā)隊(duì)列,這四個(gè)隊(duì)列分別有不同的優(yōu)先級:高、默認(rèn)、低以及后臺,用戶不能去創(chuàng)建全局隊(duì)列,只能根據(jù)優(yōu)先級去獲?。?br>
dispatch_queue_t queue;
queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
3.user create queue
用戶可以通過dispatch_queue_create自己創(chuàng)建隊(duì)列,該函數(shù)有兩個(gè)參數(shù),第一個(gè)是隊(duì)列的名稱,在debug的時(shí)候方便區(qū)分;第二個(gè)是隊(duì)列的一些屬性,NULL或者DISPATCH_QUEUE_SERIAL創(chuàng)建出來的隊(duì)列事串行隊(duì)列,如果傳遞DISPATCH_QUEUE_CONCURRENT則為并行隊(duì)列。
// 創(chuàng)建并行隊(duì)列
dispatch_queue_t queue;
queue=dispatch_queue_create(“com.example.MyQueue”, DISPATCH_QUEUE_CONCURRENT);
4.隊(duì)列優(yōu)先級
dispatch_queue_create創(chuàng)建隊(duì)列的優(yōu)先級跟global dispatch queue的默認(rèn)優(yōu)先級一樣,假如我們需要設(shè)置隊(duì)列的優(yōu)先級,可以通過dispatch_queue_attr_make_with_qos_class或者dispatch_set_target_queue方法;
Quality of Service 枚舉來使用user interactive,user initiated,utility和bakground
通過這些告訴系統(tǒng)我們在進(jìn)行什么樣的工作,然后系統(tǒng)會通過合理的資源控制來最高效的執(zhí)行任務(wù)代碼,其中主要涉及到CPU調(diào)度的優(yōu)先級、IO優(yōu)先級、任務(wù)運(yùn)行在哪個(gè)線程以及運(yùn)行的順序等等,我們通過一個(gè)抽象的Quality of Service 參數(shù)來表明任務(wù)的意圖以及類別。
一個(gè)典型的例子就是數(shù)據(jù)的讀寫,通常為了防止文件讀寫導(dǎo)致沖突,我們會創(chuàng)建一個(gè)串行的隊(duì)列,所有的文件操作都是通過這個(gè)隊(duì)列來執(zhí)行,比如FMDB,這樣就可以避免讀寫沖突。不過其實(shí)這樣是有提升空間的,當(dāng)沒有更新數(shù)據(jù)時(shí),讀操作其實(shí)是可以并行進(jìn)行的,而寫操作需要串行執(zhí)行。
Dispatch IO
當(dāng)我們要讀取一份較大文件的時(shí)候,多個(gè)線程同時(shí)去讀肯定比一個(gè)線程去讀的速度要快,要實(shí)現(xiàn)這樣的功能可以通過dispatch io跟dispatch data來實(shí)現(xiàn),通過dispatch io讀文件時(shí),會使用global dispatch queue將一個(gè)文件按照一個(gè)指定的分塊大小同時(shí)去讀區(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進(jìn)行結(jié)合和分割。
dispatch_io_create函數(shù)生成Dispatch I/O,并指定發(fā)生error時(shí)用來執(zhí)行處理的block,以及執(zhí)行該block的Dispatch Queue。
dispatch_io_set_low_water函數(shù)設(shè)置一次讀取的大小
dispatch_io_read函數(shù)使用Global Dispatch Queue開始并發(fā)讀取。每當(dāng)各個(gè)分割的文件塊讀取結(jié)束時(shí),會將含有文件塊數(shù)據(jù)的Dispatch Data(這里指pipedata)傳遞給dispatch_io_read函數(shù)指定的讀取結(jié)束時(shí)回調(diào)用的block,這個(gè)block拿到每一塊讀取好的Dispatch Data(這里指的是pipe data),然后進(jìn)行合并處理。
想提高文件讀取速度,可以嘗試使用Dispatch I/O
Dispatch Source
Dispatch Source其實(shí)就是對kqueue功能的封裝,可以去查看dispatch_source的C源碼實(shí)現(xiàn)
kqueue是在XNU內(nèi)核中發(fā)生各種事件時(shí),在應(yīng)用程序編程方執(zhí)行處理的技術(shù),其CPU負(fù)荷非常小,盡量不占用資源。
kqueue可以說是應(yīng)用程序處理XNU內(nèi)核中發(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 檢測到與進(jìn)程相關(guān)的事件
DISPATCH_SOURCE_TYPE_READ 可讀取文件映像
DISPATCH_SOURCE_TYPE_SIGNAL 接收信號
DISPATCH_SOURCE_TYPE_TIMER 定時(shí)器
DISPATCH_SOURCE_TYPE_VNODE 文件系統(tǒng)有變更
DISPATCH_SOURCE_TYPE_WRITE 可寫入文件映像
事件發(fā)生時(shí),在指定的Dispatch Queue中可執(zhí)行事件的處理。
__block size_t total = 0;
size_t size = 要讀取的字節(jié)數(shù)
char buff = (char)malloc(size);
//設(shè)定為異步映像
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事件時(shí)執(zhí)行的處理
dispatch_source_set_event_handle(source, ^{
//獲取可讀取的字節(jié)數(shù)
size_t available = dispatch_source_get_data(source);
// 從映像中讀取
int length = read(socked, buff, available);
// 發(fā)生錯(cuò)誤時(shí)取消Dispatch Source
if ( length < 0){
// 錯(cuò)誤處理
dispatch_source_cancel(source);
}
total += length;
if(total == size) {
// buff的處理
// 處理結(jié)束,取消Dispatch Source
dispatch_source_cancel(source);
}