問(wèn)題：假如現(xiàn)在有1w個(gè)任務(wù)需要執(zhí)行，并且在全部執(zhí)行完成之后進(jìn)行一個(gè)提示，該怎么做？

思路1：最直接的會(huì)想到dispatch_group，本身就是為一組任務(wù)設(shè)計(jì)的

#define OPERATION_COUNT         10000
#define OPERATION_SLEEP_TIME    0.01f

- (void)myOperation:(NSInteger)index {
    [NSThread sleepForTimeInterval:OPERATION_SLEEP_TIME];    
}

- (void)runMyOperationsWithGCD {
    dispatch_group_t group = dispatch_group_create();
    for (int i = 0; i < OPERATION_COUNT; i++) {
        dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
            [self myOperation:i];
        });
    }
    
    dispatch_group_notify(group, dispatch_get_global_queue(0, 0), ^{
        NSLog(@"operations are finished");
    });
}

思考1：這段代碼看的應(yīng)該非常清爽，但是會(huì)創(chuàng)建過(guò)多的線程，也給系統(tǒng)帶來(lái)了巨大的負(fù)擔(dān)，是需要優(yōu)化的。

問(wèn)題：假設(shè)在原始問(wèn)題的基礎(chǔ)上約束最多10個(gè)并發(fā)線程，又有什么好的辦法？

思路2：采用iOS的NSOperationQueue，這個(gè)東西簡(jiǎn)直是按照這種需求設(shè)計(jì)的，非常好用

#define MAX_CONCURRENT_COUNT 10
#define OPERATION_COUNT     10000
#define OPERATION_SLEEP_TIME    0.1f

- (void)myOperation:(NSInteger)index {
    NSLog(@"enter myOperation:%ld, thread:%@", (long)index, [NSThread currentThread]);
    [NSThread sleepForTimeInterval:OPERATION_SLEEP_TIME];    
}

- (void)runMyOPerationsWithNSOperation {
    NSOperationQueue *queue = [[NSOperationQueue alloc] init];
    queue.maxConcurrentOperationCount = MAX_CONCURRENT_COUNT;//設(shè)置最大并發(fā)數(shù)
    for (int i = 0; i < OPERATION_COUNT; i++) {
        [queue addOperationWithBlock:^{
            [self myOperation:i];
        }];
    }
        
    dispatch_async(dispatch_get_global_queue(0, 0), ^{
        [queue waitUntilAllOperationsAreFinished];//等待所有任務(wù)完成
        NSLog(@"operations are finished");
    });
}

思考2：個(gè)人覺得，這是最方便的方法，簡(jiǎn)單明了，沒有過(guò)多的線程和冗余的代碼。

問(wèn)題：如果不使用NSOperation，又有什么好的辦法嗎？

思路3：通過(guò)信號(hào)量控制并發(fā)，并結(jié)合思路1的dispatch_group實(shí)現(xiàn)組任務(wù)完成后的通知

#define MAX_CONCURRENT_COUNT 10
#define OPERATION_COUNT     10000
#define OPERATION_SLEEP_TIME    0.1f

- (void)myOperation:(NSInteger)index {
    NSLog(@"enter myOperation:%ld, thread:%@", (long)index, [NSThread currentThread]);
    [NSThread sleepForTimeInterval:OPERATION_SLEEP_TIME];
}

- (void)runMyOperationsWithSemaphore {
    //創(chuàng)建信號(hào)量，控制最大并發(fā)數(shù)為10
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(MAX_CONCURRENT_COUNT);
    dispatch_group_t group = dispatch_group_create();
    for (int i = 0; i < OPERATION_COUNT; i++) {
        //wait一次，semaphore減一，當(dāng)semaphore小于0時(shí)會(huì)一直wait
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        dispatch_group_async(group, dispatch_get_global_queue(0, 0), ^{
            [self myOperation:i];
            //任務(wù)完成后，觸發(fā)semaphore，以允許新的任務(wù)進(jìn)入
            dispatch_semaphore_signal(semaphore);
        });
    }

    dispatch_group_notify(group, dispatch_get_global_queue(0, 0), ^{
        NSLog(@"operations are finished");
    });
}

思考3：這種方式其實(shí)是在思路1的基礎(chǔ)上增加了信號(hào)量的并發(fā)限制，相當(dāng)于一種簡(jiǎn)單的改進(jìn)。

最后，如果采用最傳統(tǒng)的NSThread，跟信號(hào)量配合，可以實(shí)現(xiàn)多任務(wù)并發(fā)，但如何判斷所有任務(wù)都已執(zhí)行完畢，只想到了通過(guò)計(jì)數(shù)的方式，并沒有想到更好的辦法。如果大家有更好的辦法，歡迎留言，私信！

最最后，附上demo，地址