首先,看看如下代碼的輸出是什么摧阅?
- (void)viewDidLoad {? ? [superviewDidLoad];NSLog(@"Hello");dispatch_sync(dispatch_get_main_queue(), ^{NSLog(@"World");? ? ? ? ? ? });}
首先答案是會(huì)發(fā)生死鎖汰蓉,我們看看官方文檔關(guān)于dispatch_sync的解釋:
Submits a block to a dispatch queue like dispatch_async(), however
dispatch_sync() will not return until the block has finished.
Calls to dispatch_sync() targeting the current queue will result
in dead-lock. Use of dispatch_sync() is also subject to the same
multi-party dead-lock problems that may result from the use of a mutex.
Use of dispatch_async() is preferred.
Unlike dispatch_async(), no retain is performed on the target queue. Because
calls to this function are synchronous, the dispatch_sync() "borrows" the
reference of the caller.
As an optimization, dispatch_sync() invokes the block on the current
thread when possible.
如果dispatch_sync()的目標(biāo)queue為當(dāng)前queue,會(huì)發(fā)生死鎖(并行queue并不會(huì))棒卷。使用dispatch_sync()會(huì)遇到跟我們?cè)趐thread中使用mutex鎖一樣的死鎖問題顾孽。
話是這么說祝钢,我們看看究竟是怎么做的?先放碼:
source/queue.c
voiddispatch_sync(dispatch_queue_t dq,void(^work)(void)){structBlock_basic *bb = (void*)work;? ? dispatch_sync_f(dq, work, (dispatch_function_t)bb->Block_invoke);}DISPATCH_NOINLINEvoiddispatch_sync_f(dispatch_queue_t dq,void*ctxt, dispatch_function_t func){? ? typeof(dq->dq_running) prev_cnt;dispatch_queue_told_dq;if(dq->dq_width ==1) {returndispatch_barrier_sync_f(dq, ctxt, func);? ? }// 1) ensure that this thread hasn't enqueued anything ahead of this call// 2) the queue is not suspendedif(slowpath(dq->dq_items_tail) || slowpath(DISPATCH_OBJECT_SUSPENDED(dq))) {? ? ? ? _dispatch_sync_f_slow(dq);? ? }else{? ? ? ? prev_cnt = dispatch_atomic_add(&dq->dq_running,2) -2;if(slowpath(prev_cnt &1)) {if(dispatch_atomic_sub(&dq->dq_running,2) ==0) {? ? ? ? ? ? ? ? _dispatch_wakeup(dq);? ? ? ? ? ? }? ? ? ? ? ? _dispatch_sync_f_slow(dq);? ? ? ? }? ? }? ? old_dq = _dispatch_thread_getspecific(dispatch_queue_key);? ? _dispatch_thread_setspecific(dispatch_queue_key, dq);? ? func(ctxt);? ? _dispatch_workitem_inc();? ? _dispatch_thread_setspecific(dispatch_queue_key, old_dq);if(slowpath(dispatch_atomic_sub(&dq->dq_running,2) ==0)) {? ? ? ? _dispatch_wakeup(dq);? ? }}
Step1. 可以看到dispatch_sync將我們block函數(shù)指針進(jìn)行了一些轉(zhuǎn)換后若厚,直接傳給了dispatch_sync_f()去處理拦英。
Step2. dispatch_sync_f首先檢查傳入的隊(duì)列寬度(dq_width),由于我們傳入的main queue為串行隊(duì)列测秸,隊(duì)列寬度為1疤估,所有接下來會(huì)調(diào)用dispatch_barrier_sync_f,傳入3個(gè)參數(shù)霎冯,dispatch_sync中的目標(biāo)queue铃拇、上下文信息和由我們block函數(shù)指針轉(zhuǎn)化過后的func結(jié)構(gòu)體。
接下來我們看看dispatch_barrier_sync_f的實(shí)現(xiàn)
source/queue.c
voiddispatch_barrier_sync_f(dispatch_queue_t dq, void *ctxt, dispatch_function_tfunc){? ? dispatch_queue_t old_dq = _dispatch_thread_getspecific(dispatch_queue_key);// 1) ensure that this thread hasn't enqueued anything ahead of this call// 2) the queue is not suspended// 3) the queue is not weirdif(slowpath(dq->dq_items_tail)? ? ? ? ? ? || slowpath(DISPATCH_OBJECT_SUSPENDED(dq))? ? ? ? ? ? || slowpath(!_dispatch_queue_trylock(dq))) {return_dispatch_barrier_sync_f_slow(dq, ctxt,func);? ? }_dispatch_thread_setspecific(dispatch_queue_key, dq);func(ctxt);? ? _dispatch_workitem_inc();? ? _dispatch_thread_setspecific(dispatch_queue_key, old_dq);? ? _dispatch_queue_unlock(dq);}
Step3. disptach_barrier_sync_f首先做了做了3個(gè)判斷:
隊(duì)列存在尾部節(jié)點(diǎn)狀態(tài)(判斷當(dāng)前是不是處于隊(duì)列尾部)
隊(duì)列不為暫停狀態(tài)
使用_dispatch_queue_trylock檢查隊(duì)列能被正常加鎖沈撞。
滿足所有條件則不執(zhí)行if語句內(nèi)的內(nèi)容慷荔,執(zhí)行下面代碼,簡(jiǎn)單解釋為:
使用mutex鎖关串,獲取到當(dāng)前進(jìn)程資源鎖。
直接執(zhí)行我們block函數(shù)指針的具體內(nèi)容监徘。
然后釋放鎖晋修,整個(gè)調(diào)用結(jié)束。
然后在我們例子中凰盔,很顯然當(dāng)前隊(duì)列中還有其他viewController的任務(wù)墓卦,我們的流程跑到_dispatch_barrier_aync_f_slow()函數(shù)體中。
刨根問底户敬,讓我們看看這個(gè)函數(shù)。
source/queue.c
staticvoid_dispatch_barrier_sync_f_slow(dispatch_queue_tdq,void*ctxt,dispatch_function_tfunc){// It's preferred to execute synchronous blocks on the current thread// due to thread-local side effects, garbage collection, etc. However,// blocks submitted to the main thread MUST be run on the main threadstructdispatch_barrier_sync_slow2_s dbss2 = {? ? ? ? .dbss2_dq = dq,#ifDISPATCH_COCOA_COMPAT.dbss2_func = func,? ? ? ? .dbss2_ctxt = ctxt,#endif.dbss2_sema = _dispatch_get_thread_semaphore(),? ? };structdispatch_barrier_sync_slow_s {? ? ? ? DISPATCH_CONTINUATION_HEADER(dispatch_barrier_sync_slow_s);? ? } dbss = {? ? ? ? .do_vtable = (void*)DISPATCH_OBJ_BARRIER_BIT,? ? ? ? .dc_func = _dispatch_barrier_sync_f_slow_invoke,? ? ? ? .dc_ctxt = &dbss2,? ? };//---------------重點(diǎn)是這里---------------_dispatch_queue_push(dq, (void*)&dbss);? ? dispatch_semaphore_wait(dbss2.dbss2_sema, DISPATCH_TIME_FOREVER);? ? _dispatch_put_thread_semaphore(dbss2.dbss2_sema);#ifDISPATCH_COCOA_COMPAT// Main queue bound to main threadif(dbss2.dbss2_func ==NULL) {return;? ? }#endifdispatch_queue_told_dq = _dispatch_thread_getspecific(dispatch_queue_key);? ? _dispatch_thread_setspecific(dispatch_queue_key, dq);? ? func(ctxt);? ? _dispatch_workitem_inc();? ? _dispatch_thread_setspecific(dispatch_queue_key, old_dq);? ? dispatch_resume(dq);}
Step4. 既然我們上面已經(jīng)判斷了尿庐,main queue中還有其他任務(wù)忠怖,現(xiàn)在不能直接執(zhí)行這個(gè)block,跳入到_dispatch_barrier_sync_f_slow函數(shù)體抄瑟,那它怎么處理我們加入的block呢凡泣?
在_dispatch_barrier_sync_f_slow中,使用_dispatch_queue_push將我們的block壓入main queue的FIFO隊(duì)列中皮假,然后等待信號(hào)量鞋拟,ready后被喚醒。
然后dispatch_semaphore_wait返回_dispatch_semaphore_wait_slow(dsema, timeout)函數(shù)惹资,持續(xù)輪訓(xùn)并等待贺纲,直到條件滿足。
所以在此過程中褪测,我們最初調(diào)用的dispatch_sync函數(shù)一直得不到返回猴誊,main queue被阻塞潦刃,而我們的block又需要等待main queue來執(zhí)行它。死鎖愉快的產(chǎn)生了稠肘。
最后:
我們繪制上張圖來輕松的描述一下這個(gè)問題:
轉(zhuǎn)載:文/jackjhu ?原文鏈接:http://www.reibang.com/p/44369c02b62a?