iOS GCD的基本使用

GCD在iOS中多线程开发中使用频繁，使用方便简单，可以满足我们大部分需求。其使用方法如下：

1、基本认识

GCD以任务队列为基础的多线程管理的方案，使用者不直接调用线程，而是调用队列，往队列中添加执行任务，决定任务的执行方式。
GCD中的队列分为串行队列、并行队列，执行方式分为同步执行、异步执行。
串行队列：每次只能执行一个任务，等待任务执行完毕才能执行第下一个任务。
并行队列：每次可以执行多个任务，后面的任务不依赖前面的任务执行情况。
同步执行：执行任务时，需要当前代码执行完毕才能执行后面的代码，会阻塞当前线程
异步执行：执行任务时，当前代码不会影响后续任务外的代码的执行，不会阻塞当前线程
创建方式如下：

    self.serial_queue = dispatch_queue_create("串行队列", DISPATCH_QUEUE_SERIAL);
    
    self.concurrent_queue = dispatch_queue_create("并行队列", DISPATCH_QUEUE_CONCURRENT);

其中队列名称可自行定义。
队列和执行方式有四种组合

a、串行队列，同步执行

任务按顺序在当前线程执行，并且会阻塞当前线程，代码如下：

- (void)sync_serial_queue {
    for (int i = 0; i < 20; i++) {
        dispatch_sync(self.serial_queue, ^{
            NSLog(@"%d===%@",i,[NSThread currentThread]);
        });
    }
}

b、串行队列，异步执行

任务按顺序执行，不一定在当前线程，不会阻塞当前线程，代码如下：

- (void)async_serial_queue {
    for (int i = 0; i < 20; i++) {
        dispatch_async(self.serial_queue, ^{
            NSLog(@"%d===%@",i,[NSThread currentThread]);
        });
    }
}

c、并行队列，同步执行

任务按顺序执行，不在当前线程，会阻塞当前线程，代码如下：

- (void)sync_concurrent_queue {
    for (int i = 0; i < 20; i++) {
        dispatch_sync(self.concurrent_queue, ^{
            NSLog(@"%d===%@",i,[NSThread currentThread]);
        });
    }
}

d、并行队列，异步执行

任务不按顺序执行，不在当前线程，不会阻塞当前线程，代码如下：

- (void)async_concurrent_queue {
    for (int i = 0; i < 20; i++) {
        dispatch_async(self.concurrent_queue, ^{
            NSLog(@"%d===%@",i,[NSThread currentThread]);
        });
    }
}

iOS的系统框架提供了两个系统级队列，分别为主队列和全局队列，特性如下：
主队列：串行队列，任务只在主线程执行
全局队列：并行队列，可设置优先级
队列获取代码如下：

    //主队列
    dispatch_queue_t main_queue = dispatch_get_main_queue();
    
    //全局队列
    dispatch_queue_t global_queue = dispatch_get_global_queue(0, 0);

在一般的需求下可以使用全局队列，在代码需要在主线程环境时使用主队列。

2、dispatch barrier的使用

当我们存在以下情况，任务4依赖于任务1、任务2、任务3的执行，任务5、任务6、任务7依赖于任务4的执行，其中任务1、任务2、任务3可以分别独立执行，任务5、任务6、任务7页可以分别独立同时执行，如下图：

图片.png

则可以使用dispatch_barrier，函数有dispatch_barrier_sync和dispatch_barrier_async，区别在于dispatch_barrier_sync会阻塞后续代码的运行，dispatch_barrier_async不会阻塞后续代码的运行。两个函数代码如下：

/**
 异步并行队列，barrier同步，使barrier前面的任务全部执行完毕，才会执行barrier后面添加到queue的任务,barrier_sync会影响后阻塞后续代码的执行
 */
- (void)concurrent_queue_barier_sync {
    NSLog(@"start");
    for (int i = 0; i < 10; i++) {
        dispatch_async(self.concurrent_queue, ^{
            NSLog(@"%d===%@",i,[NSThread currentThread]);
        });
        if (i == 5) {
            NSLog(@"barrier sync");
            dispatch_barrier_sync(self.concurrent_queue, ^{
                NSLog(@"dispatch_barrier_sync===%d===%@",i,[NSThread currentThread]);
            });
        }
    }
    NSLog(@"end");
}

/**
 异步并行队列，barrier同步，使barrier前面的任务全部执行完毕，才会执行barrier后面添加到queue的任务，barrier_async不会影响后续代码的执行
 */
- (void)concurrent_queue_barier_async {
    NSLog(@"start");
    for (int i = 0; i < 10; i++) {
        dispatch_async(self.concurrent_queue, ^{
            NSLog(@"%d===%@",i,[NSThread currentThread]);
        });
        if (i == 5) {
            NSLog(@"barrier async");
            dispatch_barrier_async(self.concurrent_queue, ^{
                NSLog(@"dispatch_barrier_async===%d===%@",i,[NSThread currentThread]);
            });
        }
    }
    NSLog(@"end");
}

3、延迟执行

当我们需要延迟执行某个任务，一般情况下我们可以使用dispatch_after函数，代码如下：

- (void)dispatch_after {
    NSLog(@"%@",[NSDate date]);
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(10 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        NSLog(@"after == %@",[NSDate date]);
    });
}

swift版本

DispatchQueue.main.asyncAfter(deadline: DispatchTime.now() + 2, execute: DispatchWorkItem(block: {

}))

4、单次执行

当我们需要创建单例或者只需要代码在程序运行过程中只执行一次时，我们可以使用dispatch_once函数，代码如下：

- (void)dispatch_once {
    for (int i = 0; i < 10; i++) {
        static dispatch_once_t onceToken;
        dispatch_once(&onceToken, ^{
            NSLog(@"%d",i);
        });
    }
}

5、多线程快速迭代

当我们的数组需要在多线程情况下遍历时可以使用dispatch_apply，使用较少，代码如下：

- (void)dispatch_apply {
    dispatch_apply(10, self.concurrent_queue, ^(size_t index) {
        NSLog(@"dispatch_apply==%zud===%@",index,[NSThread currentThread]);
    });
}

6、多任务同步

当我们需要实现下面的任务时，除了第二项的dispatch_barrier，我们还可以使用dispatch_group。任务4依赖于任务1、任务2、任务3的执行，如下图：

图片.png

主要操作步骤：1、创建dispatch_group；2、把任务加入到group，等待任务执行完毕；3、任务执行完毕，调用dispatch_group_notify里面的任务。
第2步把任务加入到group中的操作有两种方法，一种是直接使用dispatch_group_async，另外一种是使用dispatch_group_enter、dispatch_group_leave两个函数，dispatch_group_enter表示进入group，dispatch_group_leave表示一个任务执行完毕，离开group。
我们也可以使用同步函数dispatch_group_wait来等待任务1、任务2、任务3执行完毕，然后执行dispatch_group_wait后面的代码。
代码如下：

- (void)dispatch_group_1 {
    dispatch_group_t group_t = dispatch_group_create();
    
    for (int i = 0; i < 10; i++) {
        dispatch_group_async(group_t, self.concurrent_queue, ^{
            NSLog(@"dispatch_group_1===%d===%@",i,[NSThread currentThread]);
        });
    }
    
    dispatch_group_notify(group_t, dispatch_get_main_queue(), ^{
        NSLog(@"转主线程");
    });
}

- (void)dispatch_group_2 {
    dispatch_group_t groutp_t = dispatch_group_create();
    
    for (int i = 0; i < 10; i++) {
        dispatch_group_enter(groutp_t);
        dispatch_async(self.concurrent_queue, ^{
            NSLog(@"dispatch_group_2===%d===%@",i,[NSThread currentThread]);
            dispatch_group_leave(groutp_t);
        });
    }
    dispatch_group_notify(groutp_t, dispatch_get_main_queue(), ^{
        NSLog(@"转主线程");
    });
}

- (void)dispatch_group_3 {
    dispatch_group_t groutp_t = dispatch_group_create();
    
    for (int i = 0; i < 10; i++) {
        dispatch_group_enter(groutp_t);
        dispatch_async(self.concurrent_queue, ^{
            NSLog(@"dispatch_group_3===%d===%@",i,[NSThread currentThread]);
            dispatch_group_leave(groutp_t);
        });
    }
    dispatch_group_wait(groutp_t, DISPATCH_TIME_FOREVER);
    NSLog(@"group end");
}

7、信号量的使用

GCD提供了信号量函数，提供我们进行线程安全操作，当信号量为0时等待操作，信号量大于0是，继续执行操作，，主要流程如下：
1、创建信号量对象，确定信号初始值
2、开始执行操作前检查是否需要等待，执行函数dispatch_semaphore_wait，如果当前的信号量为0则阻塞，等待信号量大于0时继续执行，执行函数完毕会使信号量减一。当一个任务执行完毕时我们需要调用dispatch_semaphore_signal函数，告诉系统一个任务执行完毕，调用后会使信号量加1。dispatch_semaphore_wait和dispatch_semaphore_signal函数应当成对存在，有特别需求也可以不成对存在。当初始信号量为1时，我们可以用作线程安全锁进行使用，代码如下：

- (void)dispatch_semaphore {
    dispatch_semaphore_t semaphore_t = dispatch_semaphore_create(3);
    for (int i = 0; i < 10; i++) {
        dispatch_semaphore_wait(semaphore_t, DISPATCH_TIME_FOREVER);
        dispatch_async(self.concurrent_queue, ^{
            int t = rand() % 5;
            sleep(t);
            NSLog(@"dispatch_semaphore===%d===%@===%d",i,[NSThread currentThread],t);
            dispatch_semaphore_signal(semaphore_t);
        });
    }
    NSLog(@"end");
}

8、GCD的source事件

GCD可以监听事件源对象，创建事件源对象方法如下：

dispatch_source_t
dispatch_source_create(dispatch_source_type_t type,
    uintptr_t handle,
    uintptr_t mask,
    dispatch_queue_t _Nullable queue);

事件源类型有很多种，如下所示：

    // 自定义事件,触发事件后的数据会被叠加运算
    #define DISPATCH_SOURCE_TYPE_DATA_ADD
    // 自定义事件,触发时间后的数据会被按位或运算
    #define DISPATCH_SOURCE_TYPE_DATA_OR
    // 自定义事件,触发时间后的数据会被替换
    #define DISPATCH_SOURCE_TYPE_DATA_REPLACE
    // 内核端口发送数据事件
    #define DISPATCH_SOURCE_TYPE_MACH_SEND
    // 内核端口接收数据事件
    #define DISPATCH_SOURCE_TYPE_MACH_RECV
    // 内存压力事件
    #define DISPATCH_SOURCE_TYPE_MEMORYPRESSURE
    // 进程相关事件
    #define DISPATCH_SOURCE_TYPE_PROC
    // 读文件相关事件
    #define DISPATCH_SOURCE_TYPE_READ
    // 写文件相关事件
    #define DISPATCH_SOURCE_TYPE_WRITE
    // 信号相关事件
    #define DISPATCH_SOURCE_TYPE_SIGNAL
    // 定时器事件
    #define DISPATCH_SOURCE_TYPE_TIMER
    // 文件属性修改事件
    #define DISPATCH_SOURCE_TYPE_VNODE

创建事件源之后，我们需要设置回调函数，如下：

void
dispatch_source_set_event_handler(dispatch_source_t source,
    dispatch_block_t _Nullable handler);

注意创建的dispatch_source_t对象需要我们进行强引用，持有对象。
最后我们需要激活对象，方法如下，传入dispatch_source_t作为参数。

void
dispatch_activate(dispatch_object_t object);

定时器是我们常使用的一种任务逻辑，当我们需要较高精度的定时器时我们可以使用GCD source的定时器执行任务，示例代码如下：

- (void)dispatch_source_timer {
    dispatch_source_t timer = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, self.serial_queue);
    dispatch_source_set_timer(timer, DISPATCH_TIME_NOW, 1 * NSEC_PER_SEC, 0 * NSEC_PER_SEC);
    dispatch_source_set_event_handler(timer, ^{
        NSLog(@"dispatch_source_timer %@",[NSThread currentThread]);
    });
    dispatch_activate(timer);
    self.timer = timer;
}

demo地址

最后编辑于：2024.01.08 15:33:56

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 203,324评论 5赞 476
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,303评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,192评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,555评论 1赞 273
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,569评论 5赞 365
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,566评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,927评论 3赞 395
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,583评论 0赞 257
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,827评论 1赞 297
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,590评论 2赞 320
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,669评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,365评论 4赞 318
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,941评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,928评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,159评论 1赞 259
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 42,880评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,399评论 2赞 342