IOS开发-多线程队列测试代码
直接贴测试代码了。
当前考虑的问题:
1.队列有多少个消费者
2.添加到队列的新task是同步运行(当前线程阻塞)还是异步(当前线程不阻塞)
3.多个队列之间的调度(此文章未涉及)
// //单线程和多线程并发队列测试(同步和异步) // //基础原理: //1)队列: //1.1dispatch_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" @interfaceTestQueueSi() @property(strong,nonatomic)dispatch_queue_tserialQueue; @property(strong,nonatomic)dispatch_queue_tconcurrentQueue; @end @implementationTestQueueSi -(instancetype)init{ self=[superinit]; if(self){ _serialQueue=dispatch_queue_create("chenhh.serialQueue",DISPATCH_QUEUE_SERIAL); _concurrentQueue=dispatch_queue_create("chenhh.concurrentQueue",DISPATCH_QUEUE_CONCURRENT); } returnself; } /** QUEUE_SERIAL(单线程)同步 死锁崩溃 1.ATask运行,同步加入BTask 2.BTask加入到请求队列中,可是没有其他空余线程(ATask线程在等待BTask),BTask等待空余线程, 3.死锁发生 */ -(void)testSerialQueueSync{ dispatch_sync(_serialQueue,^{ [selffooA]; dispatch_sync(_serialQueue,^{ [selffooB]; }); [selffooA]; }); } /** QUEUE_CONCURRENT(多线程)同步 正常运行 1.ATask运行,同步加入BTask,Atask线程等待 2.BTask加入到请求队列中,有其他空余线程(ATask线程在等待BTask),BTask运行 3.BTask运行结束,ATask停止等待,继续运行 */ -(void)testConcurrentQueueSync{ dispatch_sync(_concurrentQueue,^{ [selffooA]; NSLog(@"first"); //同步需要等待运行结果 dispatch_sync(_concurrentQueue,^{ [selffooB]; }); //等待同步代码完成,再运行 [selffooA]; }); } /* QUEUE_SERIAL(单线程)异步 正常 1.ATask运行,异步加入BTask,Atask线程继续运行不等待 2.BTask加入到请求队列中,没有其他空余线程(ATask线程在正常运行),BTask等待空余 3.ATask运行完成,线程空出,BTask运行 */ -(void)testSerialQueueAsync{ dispatch_async(_serialQueue,^{ [selffooA]; dispatch_async(_serialQueue,^{ [selffooB]; }); [selffooA]; }); } /** QUEUE_CONCURRENT(多线程)异步 正常运行 1.ATask运行,同步加入BTask,Atask线程继续运行不等待 2.BTask加入到请求队列中,有其他空余线程(ATask等线程在正常运行),BTask运行(ABTask同时运行) */ -(void)testConcurrentQueueAsync{ dispatch_async(_concurrentQueue,^{ [selffooA]; //同步需要等待运行结果 dispatch_async(_concurrentQueue,^{ [selffooB]; }); //等待同步代码完成,再运行 [selffooA]; }); } -(void)fooA{ NSLog(@"************fooA************"); } -(void)fooB{ NSLog(@"************fooB************"); } @end