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