GCD2 - 简书

GCD2

1. 死锁

- (void)viewDidLoad {
    [super viewDidLoad];
    dispatch_sync(dispatch_get_main_queue(), ^{
        NSLog(@"--执行任务--");
    });
}

发生死锁
原因：dispatch_sync会将任务追加到队列上，等当前的任务执行完毕，再执行Block中的任务；但是当前执行的任务viewDidLoad包含Block任务，所以会造成死锁。

2. dispatch_apply

dispatch_apply函数按照指定的次数将指定的Block追加到指定的Dispatch Queue中，并等待全部执行完成；

    NSArray *array = @[@"A", @"B", @"C", @"D", @"E", @"F", @"G", @"H", @"I", @"J"];
    dispatch_apply([array count], dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^(size_t index) {
        NSLog(@"index:%zu : value : %@", index, [array objectAtIndex:index]);
    });
    NSLog(@"--End--");

结果

dispatch_apply.png

结果：由于我用的是Global Queue，所以会乱序输出结果，并在所有结果输出完毕后，输出End

3. Dispatch Semaphore

当并行执行的处理更新数据时，会产生数据不一样的情况，有时甚至会导致程序崩溃，虽然我们可以采用dispatch_group、dispatch_barrier_async 等函数来避免这些问题，但有必要进行更细力度的排他控制

信号量的使用：

创建一个计数初始值为1的信号量

dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);

当信号量的计数值大于或等于1时，将计数值减1，并执行下面的代码；当信号量的计数值等于0时，等待

dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);

增加指定的信号量的计数值

dispatch_semaphore_signal(semaphore);

实例：向一个数组中写入10万条数据

    NSMutableArray *mutableArray = [NSMutableArray array];
    dispatch_queue_t globalQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    for (int i = 0; i < 100000; i ++) {
        dispatch_async(globalQueue, ^{
            [mutableArray addObject:[NSNumber numberWithInt:i]];
            NSLog(@"--");
        });
    }

上面的代码会因为内存过于频繁释放导致崩溃，提示pointer being freed was not allocated
解决方法：加入信号量

    NSMutableArray *mutableArray = [NSMutableArray array];
    //定义一个计数值为1的信号量
    dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);
    dispatch_queue_t globalQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    for (int i = 0; i < 100000; i ++) {
        dispatch_async(globalQueue, ^{
            //如果信号量的值大于等于1，执行写入操作；如果计数值等于0，则等待
            //这样即使有多条线程来操作数组，也会因为信号量为0而被挡在门外
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
            [mutableArray addObject:[NSNumber numberWithInt:i]];
            NSLog(@"--");
            //当某一条线程的写入操作完成，才能允许下一个线程进行写操作，此时要对信号量的计数值 +1
            dispatch_semaphore_signal(semaphore);
        });
    }

从上面看来，信号量最主要的应用就是控制线程数量，再来一个更明显的例子

    NSMutableArray *mutableArray = [NSMutableArray array];
    dispatch_queue_t globalQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    for (int i = 0; i < 100000; i ++) {
        dispatch_async(globalQueue, ^{
            NSLog(@"%d", i);
        });
    }

当利用多线程读取数据时，如果不对线程数量进行控制，会产生大量线程，给程序带来过重的负荷，显然是不合理的；
此时就可以采用信号量，合理控制线程数量

    dispatch_semaphore_t semaphore = dispatch_semaphore_create(5);
    dispatch_queue_t globalQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

    for (int i = 0; i < 100000; i ++) {
        //当第六个线程来访问的时候，semaphore的计数值为0，不允许
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        dispatch_async(globalQueue, ^{
            NSLog(@"%d", i);
        });
        //当某个线程完成一次操作，可允许下一个线程来操作
        dispatch_semaphore_signal(semaphore);
    }

最后编辑于：2019.05.27 16:18:12