1.實現(xiàn)最大并發(fā)數(shù),在iOS里,最容易使用的是NSOperationQueue,如下
NSOperationQueue *queue = [[NSOperationQueue alloc]init];
queue.maxConcurrentOperationCount = 2;
NSOperationQueue中,已經(jīng)考慮到了最大并發(fā)數(shù)的問題,并提供了maxConcurrentOperationCount屬性設(shè)置最大并發(fā)數(shù)(該屬性需要在任務(wù)添加到隊列中之前進行設(shè)置)。maxConcurrentOperationCount默認值是-1;如果值設(shè)為0,那么不會執(zhí)行任何任務(wù);如果值設(shè)為1,那么該隊列是串行的;如果大于1,那么是并行的。
2.用GCD信號量實現(xiàn)(默認你對信號量已有一定了解),如下:
-(void)maxConcurrent{
dispatch_semaphore_t semaphore = dispatch_semaphore_create(3);
for (int i=0; i<10; i++) {
float taskTime = arc4random()%10*0.1*3;
NSLog(@"開始第%d條任務(wù)",i);
[self netWork_task_requestTime:taskTime completionHandle:^{
NSLog(@"已完成第%d條任務(wù)",i);
dispatch_semaphore_signal(semaphore);
}];
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
}
}
- (void)netWork_task_requestTime:(float)time completionHandle:(void(^)(void))success {
dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(time * NSEC_PER_SEC)), dispatch_get_global_queue(0, 0), ^{
success();
});
}
得到的結(jié)果是這樣的
image.png
解釋:
我們可以看到,第1-4一共4條任務(wù)得以執(zhí)行,然后只有完成一條或多條任務(wù)后,另一條或多條才能得以執(zhí)行,控制了任務(wù)執(zhí)行的最大數(shù)量是4條。
我們信號量給的是3,從結(jié)果來看最大并發(fā)數(shù)是4,這只是跟
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);這個方法在任務(wù)前還是后執(zhí)行有關(guān),如下:
-(void)maxConcurrent{
dispatch_semaphore_t semaphore = dispatch_semaphore_create(3);
for (int i=0; i<10; i++) {
float taskTime = arc4random()%10*0.1*3;
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
NSLog(@"開始第%d條任務(wù)",i+1);
[self netWork_task_requestTime:taskTime completionHandle:^{
NSLog(@"已完成第%d條任務(wù)",i+1);
dispatch_semaphore_signal(semaphore);
}];
}
}

image.png