GCD 学习(-) dispatch_group


如果想在dispatch_queue中所有的任务执行完成后在做某种操作,在串行队列中,可以把该操作放到最后一个任务执行完成后继续,但是在并行队列中怎么做呢。这就有dispatch_group 成组操作。比如

 dispatch_queue_t dispatchQueue = dispatch_queue_create("ted.queue.next", DISPATCH_QUEUE_CONCURRENT);
    dispatch_group_t dispatchGroup = dispatch_group_create();
    dispatch_group_async(dispatchGroup, dispatchQueue, ^(){
        NSLog(@"dispatch-1");
    });
    dispatch_group_async(dispatchGroup, dispatchQueue, ^(){
        NSLog(@"dspatch-2");
    });
    dispatch_group_notify(dispatchGroup, dispatch_get_main_queue(), ^(){
        NSLog(@"end");
    });
    /*
    上面的 log1 和log2输出顺序不定,因为是在并行队列上执行,当并行队列全部执行完成后,最后到main队列上执行一个操作,保证“end”是最后输出。 另外,这里也可以不用创建自己的并行队列,用全局的global,那个也是个并行队列. dispatch_get_gloable_queue(0,0);


    */

GCD学习(二) dispatch_barrier_async

关于 dispatch_barrier_sync 和 dispatch_barrier_async 这个可以理解为给 dispatch_sync和dispatch_async 加了一把锁 当这个 barrier block到队列头时,他会等待前面正在执行的block执行完才开始执行自己,执行本身的同时,后面的block等待barrier block 执行完毕才会继续执行。这保证了它能单独执行.

dispatch_queue_t concurrentqueue = dispatch_queue_create("com.lekan.www", DISPATCH_QUEUE_CONCURRENT);

    dispatch_async(concurrentqueue, ^{
        NSLog(@"task-1");
    });

    dispatch_async(concurrentqueue, ^{
        NSLog(@"task-2");
    });

    dispatch_barrier_async(concurrentqueue , ^{
        NSLog(@"barrier...");
    });


    dispatch_async(concurrentqueue, ^{
        NSLog(@"task-3");
    });

    dispatch_async(concurrentqueue, ^{
        NSLog(@"task-4");
    });
  • dispatch_barrier_async 作用是在并行队列中,等待前面两个操作并行操作完成,这里是并行输出 task-1,task-2 然后执行 dispatch_barrier_async中的操作,(现在就只会执行这一个操作)执行完成后,即输出 barrier, 最后该并行队列恢复原有执行状态,继续并行执行 task-3,task-4 con

GCD学习(三) dispatch_apply


dispathc_apply 是dispatch_sync 和dispatch_group的关联API.它以指定的次数将指定的Block加入到指定的队列中。并等待队列中操作全部完成.

 NSArray *array = @[@"/Users/elly/Desktop/lanfariy/GZIPDemo/GZIPDemo/NSData+GZIP.h",
                       @"/Users/elly/Desktop/lanfariy/GZIPDemo/GZIPDemo/NSData+GZIP.m",
                       @"/Users/elly/Desktop/lanfariy/GZIPDemo/GZIPDemo/ViewController.h",
                       @"/Users/elly/Desktop/lanfariy/GZIPDemo/GZIPDemo/ViewController.m",
                       @"/Users/elly/Desktop/lanfariy/GZIPDemo/GZIPDemo/main.m"
                       ];

    NSString *copyDes = @"/Users/elly/Desktop/lanfariy/test";

    NSFileManager *fileManager = [NSFileManager defaultManager];
    dispatch_async(dispatch_get_global_queue(0, 0), ^{
        dispatch_apply(array.count, dispatch_get_global_queue(0, 0), ^(size_t index) {
            NSLog(@"copy %ld",index);
            NSString *sourcePatch = [array objectAtIndex:index];
            NSString *desPath = [NSString stringWithFormat:@"%@/%@",copyDes,[sourcePatch lastPathComponent]];
            [fileManager copyItemAtPath:sourcePatch toPath:desPath error:nil];
        });
        NSLog(@"done");
    });
  • 输出 copy-index 顺序不确定,因为它是并行执行的(dispatch_get_global_queue是并行队列),但是done是在以上拷贝操作完成后才会执行,因此,它一般都是放在dispatch_async里面(异步)。实际上,这里 dispatch_apply如果换成串行队列上,则会依次输出index,但这样违背了我们想并行提高执行效率的初衷。 dispatch_apply

    GCD 学习(四)dispatch_semaphore


dispatch_semaphore 信号量基于计数器的一种多线程同步机制。在多个线程访问共有资源时候,会因为多线程的特性而引发数据出错的问题。

dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);

    NSMutableArray *arrayM = [NSMutableArray array];
    for (int i = 0; i < 1000; i++) {
         dispatch_async(dispatch_get_global_queue(QOS_CLASS_UNSPECIFIED, 0), ^{
             dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
             NSLog(@"index-%d",i);
             [arrayM addObject:@(i)];
             dispatch_semaphore_signal(semaphore);
         });
    }
  • dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); 如果semaphore计数大于等于1.计数-1,返回,程序继续运行。如果计数为0,则等待。这里设置的等待时间是一直等待。dispatch_semaphore_signal(semaphore);计数+1.在这两句代码中间的执行代码,每次只会允许一个线程进入,这样就有效的保证了在多线程环境下,只能有一个线程进入。

results matching ""

    No results matching ""