直接貼測試代碼了。
當前考慮的問題:
1.隊列有多少個消費者
2.添加到隊列的新task是同步運行(當前線程阻塞)還是異步(當前線程不阻塞)
3.多個隊列之間的調度(此文章未涉及)
//// 單線程和多線程并發隊列測試(同步和異步)//// 基礎原理:// 1)隊列:// 1.1 dispatch_queue_t 是一個隊列,一個FIFO的消費隊列// 1.2 消費者:隊列配置的運行線程// 1.3 被消費對象: 添加到隊列中的運行任務(block等)// 1.4 運行任務:將任務放到隊列中,等待消費者消費// 2)同步,異步 (對于任務) (此處的運行指將任務發入到請求隊列中)// 2.1 同步:A任務在運行時,插入B任務,A任務等待B任務運行完才能運行// 2.2 異步: A任務在運行時,插入B任務,A任務不等待并且繼續運行,B任務也運行// 假設:// ATask: 運行fooA的Block// BTask: 運行fooB的Block////// 總結:// 不管單線程或多線程,同步或異步,一定要聯系請求隊列考慮#import "TestQueueSi.h"@interface TestQueueSi ()@property (strong,nonatomic) dispatch_queue_t serialQueue;@property (strong,nonatomic) dispatch_queue_t concurrentQueue;@end@implementation TestQueueSi- (instancetype)init { self = [super init]; if(self) { _serialQueue = dispatch_queue_create("chenhh.serialQueue", DISPATCH_QUEUE_SERIAL); _concurrentQueue = dispatch_queue_create("chenhh.concurrentQueue", DISPATCH_QUEUE_CONCURRENT); } return self;}/** QUEUE_SERIAL(單線程) 同步 死鎖崩潰 1.ATask運行,同步加入BTask 2.BTask加入到請求隊列中,可是沒有其他空余線程(ATask線程在 等待BTask),BTask等待空余線程, 3.死鎖發生 */- (void)testSerialQueueSync { dispatch_sync(_serialQueue,^{ [self fooA]; dispatch_sync(_serialQueue,^{ [self fooB]; }); [self fooA]; });}/** QUEUE_CONCURRENT(多線程) 同步 正常運行 1.ATask運行,同步加入BTask,Atask線程等待 2.BTask加入到請求隊列中,有其他空余線程(ATask線程在等待BTask),BTask運行 3.BTask運行結束,ATask停止等待,繼續運行 */- (void)testConcurrentQueueSync { dispatch_sync(_concurrentQueue,^{ [self fooA]; NSLog(@"first"); // 同步 需要等待運行結果 dispatch_sync(_concurrentQueue,^{ [self fooB]; }); // 等待同步代碼完成,再運行 [self fooA]; });}/* QUEUE_SERIAL(單線程) 異步 正常 1.ATask運行,異步加入BTask,Atask線程繼續運行不等待 2.BTask加入到請求隊列中,沒有其他空余線程(ATask線程在正常運行),BTask等待空余 3.ATask運行完成,線程空出,BTask運行 */- (void)testSerialQueueAsync { dispatch_async(_serialQueue,^{ [self fooA]; dispatch_async(_serialQueue,^{ [self fooB]; }); [self fooA]; });}/** QUEUE_CONCURRENT(多線程) 異步 正常運行 1.ATask運行,同步加入BTask,Atask線程繼續運行不等待 2.BTask加入到請求隊列中,有其他空余線程(ATask等線程在正常運行),BTask運行(ABTask同時運行) */- (void)testConcurrentQueueAsync { dispatch_async(_concurrentQueue,^{ [self fooA]; // 同步 需要等待運行結果 dispatch_async(_concurrentQueue,^{ [self fooB]; }); // 等待同步代碼完成,再運行 [self fooA]; });}- (void)fooA { NSLog(@" ************ fooA ************ ");}- (void)fooB { NSLog(@" ************ fooB ************ ");}@end
新聞熱點
疑難解答