iOS_多线程_GCD_顺序执行

多个任务同时执行,全部执行完毕再执行其他的操作

(1)dispatch_group_async、dispatch_group_notify结合使用

/// 队列组
dispatch_group_t group = dispatch_group_create();
/// 并发队列
dispatch_queue_t queue = dispatch_get_global_queue(0, 0);

dispatch_group_async(group, queue, ^{
    NSLog(@"任务一:%@",[NSThread currentThread]);
});

dispatch_group_async(group, queue, ^{
    NSLog(@"任务二:%@",[NSThread currentThread]);
});

dispatch_group_async(group, queue, ^{
    NSLog(@"任务三:%@",[NSThread currentThread]);
});

dispatch_group_notify(group, queue, ^{
    NSLog(@"所有任务执行完毕:%@",[NSThread currentThread]);
});

#打印结果:
任务一、任务二、任务三(顺序不一定,因为都是异步同时执行的)都执行完成,才执行:所有任务执行完毕

(2) 使用栅栏函数

/// 自定义并发队列
dispatch_queue_t queue = dispatch_queue_create("my_queue", DISPATCH_QUEUE_CONCURRENT);

dispatch_async(queue, ^{
    NSLog(@"任务一:%@",[NSThread currentThread]);
});

dispatch_async(queue, ^{
    NSLog(@"任务二:%@",[NSThread currentThread]);
});

dispatch_async(queue, ^{
    NSLog(@"任务三:%@",[NSThread currentThread]);
});

dispatch_barrier_async(queue, ^{
    NSLog(@"所有任务执行完毕:%@",[NSThread currentThread]);
});

# 打印结果:
2020-10-13 16:24:17.926220+0800 ThreadingDemo[26902:6624494] 任务二:<NSThread: 0x600001638b80>{number = 4, name = (null)}
2020-10-13 16:24:17.926227+0800 ThreadingDemo[26902:6624499] 任务一:<NSThread: 0x60000163d5c0>{number = 6, name = (null)}
2020-10-13 16:24:17.926220+0800 ThreadingDemo[26902:6624495] 任务三:<NSThread: 0x60000163d500>{number = 5, name = (null)}
2020-10-13 16:24:17.926396+0800 ThreadingDemo[26902:6624495] 所有任务执行完毕:<NSThread: 0x60000163d500>{number = 5, name = (null)}

以上的两种写法对于任务是同步的,是没有问题的。
但是如果对于异步执行的任务,则会达不到顺序执行的,比如网络请求.
因为异步,请求还没回来,dispatch_group_notify或dispatch_barrier_async已经执行了

如果任务是异步的,可以使用信号量或者dispatch_group_enterdispatch_group_leave事项

# 比如下方任务是异步的网络请求,那么栅栏函数也是控制不住执行顺序的

- (void)viewDidLoad {
    [super viewDidLoad];
    
    dispatch_queue_t queue = dispatch_queue_create("my_queue", DISPATCH_QUEUE_CONCURRENT);
    dispatch_async(queue, ^{
        [self requestNetworkWithCallback:^{
            NSLog(@"任务1");
        }];
    });
    
    dispatch_async(queue, ^{
        [self requestNetworkWithCallback:^{
            NSLog(@"任务2");
        }];
    });
    
    dispatch_async(queue, ^{
        [self requestNetworkWithCallback:^{
            NSLog(@"任务3");
        }];
    });
    
    dispatch_barrier_async(queue, ^{
        NSLog(@"任务全部执行完成");
    });
    
}

/// 异步任务:模拟网络请求
- (void)requestNetworkWithCallback:(void(^)(void))callback {
    dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
    dispatch_async(queue, ^{
        [NSThread sleepForTimeInterval:2];
        if (callback) {
            callback();
        }
    });
}

# 打印结果:(“任务全部执行完成”肯定都是先执行的)
2020-10-14 09:36:32.053314+0800 ThreadingDemo[45423:6822309] 任务全部执行完成
2020-10-14 09:36:34.053708+0800 ThreadingDemo[45423:6822308] 任务1
2020-10-14 09:36:34.053729+0800 ThreadingDemo[45423:6822310] 任务2
2020-10-14 09:36:34.053733+0800 ThreadingDemo[45423:6822307] 任务3

(3)信号量

信号量的作用:线程同步、线程加锁
dispatch_semaphore_t dispatch_semaphore_create(long value):方法接收一个long类型的参数,返回一个dispatch_semaphore_t类型的信号量,值为传入的参数
long dispatch_semaphore_wait(dispatch_semaphore_t dsema, dispatch_time_t timeout):接收一个信号和时间值,若信号的量为0,则会阻塞当前线程,知道信号量大于0或者经过输入的时间值;若信号量大于0,则会使信号量减1并返回,程序继续往下执行
long dispatch_semaphore_signal(dispatch_semaphore_t dsema):使信号量加1并返回

# 对于多个任务同时进行,执行完成后再执行其他任务,用单个信号量完成不了
# 只能是一个个任务执行完成再执行另外一个任务
# 使用场景:多张图片,一张张上传
- (void)viewDidLoad {
    [super viewDidLoad];
    
    dispatch_queue_t queue = dispatch_queue_create("my_queue", DISPATCH_QUEUE_CONCURRENT);
    dispatch_async(queue, ^{
        /// 创建信号量,并设置为0
        dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
        
        [self requestNetworkWithTime:1 callback:^{
            NSLog(@"任务1");
            /// 信号量 + 1
            dispatch_semaphore_signal(semaphore);
        }];
        
        /// 判断如果信号量为0,则阻塞等待
        /// 信号量大于1,则会使信号量减 1,程序继续往下执行
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        NSLog(@"任务2");
        
    });
    
}

/// 异步任务:模拟网络请求
- (void)requestNetworkWithTime:(NSInteger )time callback:(void(^)(void))callback {
    dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
    dispatch_async(queue, ^{
        [NSThread sleepForTimeInterval:time];
        if (callback) {
            callback();
        }
    });
}

# 打印结果:
2020-10-14 13:51:20.956845+0800 ThreadingDemo[59313:7012870] 任务1
2020-10-14 13:51:20.957029+0800 ThreadingDemo[59313:7012871] 任务2
# 创建多个信号,异步同时执行任务,都执行完成再执行其他操作

- (void)viewDidLoad {
    [super viewDidLoad];
    
    dispatch_group_t group = dispatch_group_create();
    dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
    
    dispatch_group_async(group, queue, ^{
        /// 创建信号1
        dispatch_semaphore_t semap = dispatch_semaphore_create(0);
        [self requestNetworkWithTime:2 callback:^{
            NSLog(@"任务1");
            dispatch_semaphore_signal(semap);
        }];
        dispatch_semaphore_wait(semap, DISPATCH_TIME_FOREVER);
    });
    
    dispatch_group_async(group, queue, ^{
        /// 创建信号2
        dispatch_semaphore_t semap = dispatch_semaphore_create(0);
        [self requestNetworkWithTime:1 callback:^{
            NSLog(@"任务2");
            dispatch_semaphore_signal(semap);
        }];
        dispatch_semaphore_wait(semap, DISPATCH_TIME_FOREVER);
    });
    
    dispatch_group_notify(group, queue, ^{
        NSLog(@"全部执行完成");
    });
}

/// 异步任务:模拟网络请求
- (void)requestNetworkWithTime:(NSInteger )time callback:(void(^)(void))callback {
    dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
    dispatch_async(queue, ^{
        [NSThread sleepForTimeInterval:time];
        if (callback) {
            callback();
        }
    });
}

# 打印结果:
2020-10-14 15:42:34.781421+0800 ThreadingDemo[76163:7169489] 任务2
2020-10-14 15:42:35.781343+0800 ThreadingDemo[76163:7169490] 任务1
2020-10-14 15:42:35.781643+0800 ThreadingDemo[76163:7169495] 全部执行完成

(4)dispatch_group_enter/leave

dispatch_group_enterdispatch_group_leave 必须成对出现,否则会造成“死锁”
dispatch_group_wait:如果enter数不等于leave数,则线程阻塞等待,若enter数与leave数相等则继续往下执行
dispatch_group_notify:只有enter数和leave数相等,才会执行

- (void)viewDidLoad {
    [super viewDidLoad];
    
    dispatch_group_t group = dispatch_group_create();
    
    dispatch_group_enter(group);
    [self requestNetworkWithTime:1 callback:^{
        NSLog(@"任务1");
        dispatch_group_leave(group);
    }];
    
    dispatch_group_enter(group);
    [self requestNetworkWithTime:2 callback:^{
        NSLog(@"任务2");
        dispatch_group_leave(group);
    }];
    
    /// 等待任务1、任务2执行完毕
    dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
    
    dispatch_group_enter(group);
    [self requestNetworkWithTime:2 callback:^{
        NSLog(@"任务3");
        dispatch_group_leave(group);
    }];
    
    dispatch_group_notify(group, dispatch_get_global_queue(0, 0), ^{
        NSLog(@"全部执行完成");
    });
}

/// 异步任务:模拟网络请求
- (void)requestNetworkWithTime:(NSInteger )time callback:(void(^)(void))callback {
    dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
    dispatch_async(queue, ^{
        [NSThread sleepForTimeInterval:time];
        if (callback) {
            callback();
        }
    });
}

# 打印结果:
2020-10-14 15:18:03.405899+0800 ThreadingDemo[74573:7126913] 任务1
2020-10-14 15:18:04.407338+0800 ThreadingDemo[74573:7126917] 任务2
2020-10-14 15:18:06.410904+0800 ThreadingDemo[74573:7126917] 任务3
2020-10-14 15:18:06.411069+0800 ThreadingDemo[74573:7126917] 全部执行完成

补充:栅栏函数dispatch_barrier使用教程

dispatch_barrier_async:无需等待栅栏函数执行完成,会继续往下走(任务执行顺序:栅栏前的任务===》栅栏函数 ====》 栅栏函数后的任务)
dispatch_barrier_sync:需要等待栅栏函数执行完才会执行栅栏后面的任务
注意
(1)栅栏必须在并发队列执行 ,并且不能使用全局队列,否则栅栏函数就不起作用;
dispatch_barrier_async 等同于 dispatch_async , dispatch_barrier_sync 等同于 dispatch_sync
(2)理解的时候,必须要区分哪些是任务,哪些是普通代码

# dispatch_barrier_async

- (void)viewDidLoad {
    [super viewDidLoad];
    
    NSLog(@"start");
    dispatch_queue_t queue = dispatch_queue_create("my_queue", DISPATCH_QUEUE_CONCURRENT);
    dispatch_async(queue, ^{
        NSLog(@"任务1");
    });
   
    dispatch_async(queue, ^{
        NSLog(@"任务2");
    });
    
    ///  因为是栅栏异步,所以栅栏函数和栅栏函数后面的任务都
    dispatch_barrier_async(queue, ^{
        NSLog(@"===== barrier ====");
    });
    NSLog(@"mid");
    dispatch_async(queue, ^{
        NSLog(@"任务3");
    });
    dispatch_async(queue, ^{
        NSLog(@"任务4");  
    });
    NSLog(@"last");
}

打印结果:
2020-10-13 16:02:03.843934+0800 ThreadingDemo[26494:6576066] start
2020-10-13 16:02:03.844143+0800 ThreadingDemo[26494:6576066] mid
2020-10-13 16:02:03.844189+0800 ThreadingDemo[26494:6576341] 任务1
2020-10-13 16:02:03.844182+0800 ThreadingDemo[26494:6576343] 任务2
2020-10-13 16:02:03.844231+0800 ThreadingDemo[26494:6576066] last
2020-10-13 16:02:03.844300+0800 ThreadingDemo[26494:6576343] ===== barrier ====
2020-10-13 16:02:03.844375+0800 ThreadingDemo[26494:6576343] 任务3
2020-10-13 16:02:03.844381+0800 ThreadingDemo[26494:6576341] 任务4
# dispatch_barrier_sync

- (void)viewDidLoad {
    [super viewDidLoad];
    
    NSLog(@"start");
    dispatch_queue_t queue = dispatch_queue_create("my_queue", DISPATCH_QUEUE_CONCURRENT);
    dispatch_async(queue, ^{
        NSLog(@"任务1");
    });
    
    dispatch_async(queue, ^{
        NSLog(@"任务2");
    });
    
    /// 因为是同步栅栏,执行顺序:栅栏前 ===》栅栏函数 ====》 栅栏后
    dispatch_barrier_sync(queue, ^{
        NSLog(@"===== barrier ====");
    });
    NSLog(@"mid");
    dispatch_async(queue, ^{
        NSLog(@"任务3");
    });
    dispatch_async(queue, ^{
        NSLog(@"任务4");
    });
    NSLog(@"last");
}

打印结果:
2020-10-13 16:02:42.629822+0800 ThreadingDemo[26527:6577198] start
2020-10-13 16:02:42.630035+0800 ThreadingDemo[26527:6577356] 任务1
2020-10-13 16:02:42.630037+0800 ThreadingDemo[26527:6577360] 任务2
2020-10-13 16:02:42.630155+0800 ThreadingDemo[26527:6577198] ===== barrier ====
2020-10-13 16:02:42.630224+0800 ThreadingDemo[26527:6577198] mid
2020-10-13 16:02:42.630310+0800 ThreadingDemo[26527:6577198] last
2020-10-13 16:02:42.630327+0800 ThreadingDemo[26527:6577360] 任务3
2020-10-13 16:02:42.630374+0800 ThreadingDemo[26527:6577356] 任务4
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,588评论 6 496
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,456评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,146评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,387评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,481评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,510评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,522评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,296评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,745评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,039评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,202评论 1 343
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,901评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,538评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,165评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,415评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,081评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,085评论 2 352