iOS开发之线程组解决请求多个接口数据,完成后,再刷新界面

摘要:
在异步任务开始之前调用;dispatch_ group_ Leave:手动表示已执行块。以一种不用于dispatch_ group_异步方法离开线程组,并在异步任务执行完成后调用;如果没有添加进入或离开,将首先执行所有外围方法操作,然后执行块中的内容。这样,无法实现在所有数据完成后刷新主界面的操作。
1.多任务请求接口,完成后,在刷新数据,常用方法

2018年07月18日 16:34:38 hbblzjy 阅读数:1382

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/hbblzjy/article/details/81100453

//线程组解决同一个界面需要请求多个接口数据,当全部请求完成后,再进入主线程刷新界面

    /*

     这种问题使用 dispatch_group_enter(grpupE);来解决,dispatch_group_enter 和 dispatch_group_leave 必须要成对出现;

     dispatch_group_enter : 使用一种手动的方式将另外一个 block 以不同于 dispatch_group_async 的方式添加到线程组中。在异步任务开始之前调用;

     dispatch_group_leave : 手动指示一个 block 块执行完毕。以一种不用于 dispatch_group_async 的方式离开线程组,在异步任务执行完成之后调用;

     如果不添加enter、leave,那么将会先执行完所有的外围方法操作,然后才会执行block中的内容,这样就无法实现数据全部完成后再刷新主界面的操作。其实这不难理解,比如block是在A方法中,block的执行,都是在A方法执行完后才会执行的

     */

//1、不开启子线程的线程组简化方式

    dispatch_group_t group = dispatch_group_create();

    //模拟网络请求1

    dispatch_group_enter(group);

    //实际运用时,用网络请求的方法代替下面的内容,不要忘记leave      异步

    dispatch_async(dispatch_get_global_queue(0, 0), ^{

        for (int i = 0; i < 5; i++) {

            [NSThread sleepForTimeInterval:1];

            NSLog(@"当前线程:%@,是否是主线程:%@...1111···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//当前线程:<NSThread: 0x60000027ef40>{number = 3, name = (null)},是否是主线程:否...1111···0

        }

        dispatch_group_leave(group);

    });

    NSLog(@"当前线程:%@,是否是主线程:%@...4444···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//当前线程:<NSThread: 0x604000071d40>{number = 1, name = main},是否是主线程:是...4444···

    //模拟网络请求2

    dispatch_group_enter(group);

    //实际运用时,用网络请求的方法代替下面的内容,不要忘记leave      异步

    dispatch_async(dispatch_get_global_queue(0, 0), ^{

        for (int i = 0; i < 5; i++) {

            [NSThread sleepForTimeInterval:1];

            NSLog(@"当前线程:%@,是否是主线程:%@...2222···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//当前线程:<NSThread: 0x604000272540>{number = 4, name = (null)},是否是主线程:否...2222···0

        }

        dispatch_group_leave(group);

    });

    dispatch_group_notify(group, dispatch_get_main_queue(), ^{

        NSLog(@"当前线程:%@,是否是主线程:%@...3333···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//当前线程:<NSThread: 0x604000071d40>{number = 1, name = main},是否是主线程:是...3333···

    });

结果如图:

pastedGraphic.png



//2、开启子线程的线程组

    //一个并发队列

    dispatch_queue_t queueE = dispatch_queue_create("group.queue", DISPATCH_QUEUE_CONCURRENT);

    //一个线程组

    dispatch_group_t groupE = dispatch_group_create();

    dispatch_group_async(groupE, queueE, ^{

        NSLog(@"当前线程:%@,是否是主线程:%@...1111···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//当前线程:<NSThread: 0x60400026a540>{number = 3, name = (null)},是否是主线程:否...1111···

        //模拟网络请求1

        dispatch_group_enter(groupE);

        //实际运用时,用网络请求的方法代替下面的内容,不要忘记leave      异步

        dispatch_async(dispatch_get_global_queue(0, 0), ^{

            for (int i = 0; i < 5; i++) {

                [NSThread sleepForTimeInterval:1];

                NSLog(@"当前线程:%@,是否是主线程:%@...2222···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//当前线程:<NSThread: 0x60400026a540>{number = 3, name = (null)},是否是主线程:否...2222···0

            }

            dispatch_group_leave(groupE);

        });

    });

    dispatch_group_async(groupE, queueE, ^{

        NSLog(@"当前线程:%@,是否是主线程:%@...3333···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//当前线程:<NSThread: 0x60400026a900>{number = 4, name = (null)},是否是主线程:否...3333···

        //模拟网络请求2

        dispatch_group_enter(groupE);

        //实际运用时,用网络请求的方法代替下面的内容,不要忘记leave      异步

        dispatch_async(dispatch_get_global_queue(0, 0), ^{

            for (int i = 0; i < 5; i++) {

                [NSThread sleepForTimeInterval:1];

                NSLog(@"当前线程:%@,是否是主线程:%@...4444···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//当前线程:<NSThread: 0x60000026cac0>{number = 5, name = (null)},是否是主线程:否...4444···0

            }

            dispatch_group_leave(groupE);

        });

    });

    dispatch_group_async(groupE, queueE, ^{

        NSLog(@"当前线程:%@,是否是主线程:%@...5555···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//当前线程:<NSThread: 0x60000026cac0>{number = 5, name = (null)},是否是主线程:否...5555···

        //模拟网络请求3

        dispatch_group_enter(groupE);

        //实际运用时,用网络请求的方法代替下面的内容,不要忘记leave      异步

        dispatch_async(dispatch_get_global_queue(0, 0), ^{

            for (int i = 0; i < 5; i++) {

                [NSThread sleepForTimeInterval:1];

                NSLog(@"当前线程:%@,是否是主线程:%@...6666···%d",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否",i);//当前线程:<NSThread: 0x60400026a900>{number = 4, name = (null)},是否是主线程:否...6666···0

            }

            dispatch_group_leave(groupE);

        });

    });

    //    dispatch_group_notify(groupE, queueE, ^{

//        NSLog(@"当前线程:%@,是否是主线程:%@...7777···",[NSThread currentThread],[NSThread isMainThread]?@"":@"");//当前线程:<NSThread: 0x60400026a540>{number = 3, name = (null)},是否是主线程:否...7777···

//        dispatch_async(dispatch_get_main_queue(), ^{

//            NSLog(@"当前线程:%@,是否是主线程:%@...8888···",[NSThread currentThread],[NSThread isMainThread]?@"":@"");//当前线程:<NSThread: 0x604000069700>{number = 1, name = main},是否是主线程:是...8888···

//        });

//    });

    //简化上一种形式

    dispatch_group_notify(groupE, dispatch_get_main_queue(), ^{

        NSLog(@"当前线程:%@,是否是主线程:%@...7777···",[NSThread currentThread],[NSThread isMainThread]?@"是":@"否");//当前线程:<NSThread: 0x604000071d40>{number = 1, name = main},是否是主线程:是...7777···

    });

结果如图:

pastedGraphic_1.png

pastedGraphic_2.png

当取消了enter和leave语句后:

pastedGraphic_3.png

版权所有,转载请注明出处,谢谢~~~不喜勿喷!谢谢

【多线程】多个请求完成以后再执行其他操作

pastedGraphic.png 大基本功 关注

2018.06.19 14:46 字数 62 阅读 24评论 0喜欢 0

有时会出现这样一种情况,比如某个页面需请求多个接口获取数据后刷新UI界面,直接上代码使用GCD完成

1.完成数据后回调

- (void)getAdHotTopDataBaseRequestisScu:(void(^)(BOOL isScu))requestisScu{  

    WEAKBLOCK;  

    [self.topAddArray removeAllObjects];  

    NSString *urlStr = @"Ad/fx_top";  

    [LFNetWorkManager requestDataBaseWithURLByGET:urlStr parameters:nil isWithToken:NO completed:^(id responseObject) {  

        if([responseObject[@"code"] integerValue] == 200){  

             [ToosZFJ readAndWriteHomeListDataBase:responseObject fileName:[urlStr stringFromMD5] completed:nil];//这个是我写的缓存数据的方法  

            NSArray *data = responseObject[@"data"];  

            for (NSDictionary *dict in data) {  

                ADModel *model = [[ADModel alloc]init];  

                [model setValuesForKeysWithDictionary:dict];  

                model.mid = dict[@"id"];  

                if([dict[@"circle"] integerValue] == 1){  

                    //话题  

                }else{  

                    //头部轮播广告  

                    [weakSelf.topAddArray addObject:model];  

                }  

            }  

        }else{  

            [weakSelf SHOWPrompttext:responseObject[@"message"]];  

        }  

        if(requestisScu){  

            requestisScu((200 == [responseObject[@"code"] integerValue])?YES:NO);  

        }  

    }];  

}  

2.发起异步请求并监听

- (void)startAllRequest{  

    [self showMBProgressHUDLoding:nil];  

      

    

      

    dispatch_group_t group = dispatch_group_create();  

    dispatch_queue_t queue= dispatch_get_global_queue(0, 0);  

    // 广告数组  

    dispatch_group_enter(group);  

    dispatch_group_async(group, queue, ^{

             [self getAdHotTopDataBaseRequestisScu:^(BOOL isScu) {  

        dispatch_group_leave(group);  

    }];  

    });

    

      

    // 我的关注  

    dispatch_group_enter(group);  

    dispatch_group_async(group, queue, ^{

            [self getDataOfSOurcesFoucesRequestisScu:^(BOOL isScu) {  

        dispatch_group_leave(group);  

    }];  

    });

   

      

    // 推荐比赛  

    dispatch_group_enter(group);  

    dispatch_group_async(group, queue, ^{

           [self getDataSourcesCompareRequestisScu:^(BOOL isScu) {  

        dispatch_group_leave(group);  

    }];  

    });

    

      

    dispatch_group_notify(group, dispatch_get_main_queue(), ^{  

        [weakSelf RemoveMBProgressHUDLoding:nil];  

        [weakSelf.collectionView reloadData];  

        [weakSelf endRefreshingForTableView:weakSelf.collectionView];  

    });  

}

2.多任务,请求数据,完成后的第二种方法,  简单美姊姊

使用第三方库来实现

https://www.cnblogs.com/sundaysgarden/articles/10365574.html

3.使用dispatch_semaphore_t控制多个线程使用系统资源

iOS GCD中级篇 - dispatch_semaphore(信号量)的理解及使用

理解这个概念之前,先抛出一个问题

问题描述:

假设现在系统有两个空闲资源可以被利用,但同一时间却有三个线程要进行访问,这种情况下,该如何处理呢?

或者

我们要下载很多图片,并发异步进行,每个下载都会开辟一个新线程,可是我们又担心太多线程肯定cpu吃不消,那么我们这里也可以用信号量控制一下最大开辟线程数。

定义: 

1、信号量:就是一种可用来控制访问资源的数量的标识,设定了一个信号量,在线程访问之前,加上信号量的处理,则可告知系统按照我们指定的信号量数量来执行多个线程。

其实,这有点类似锁机制了,只不过信号量都是系统帮助我们处理了,我们只需要在执行线程之前,设定一个信号量值,并且在使用时,加上信号量处理方法就行了。

2、信号量主要有3个函数,分别是:

1

2

3

4

5

6

7

8

//创建信号量,参数:信号量的初值,如果小于0则会返回NULL

dispatch_semaphore_create(信号量值)

//等待降低信号量

dispatch_semaphore_wait(信号量,等待时间)

//提高信号量

dispatch_semaphore_signal(信号量)

  

注意,正常的使用顺序是先降低然后再提高,这两个函数通常成对使用。 (具体可参考下面的代码示例) 

3、那么就开头提的问题,我们用代码来解决

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

-(void)dispatchSignal{

    //crate的value表示,最多几个资源可访问

    dispatch_semaphore_t semaphore = dispatch_semaphore_create(2);   

    dispatch_queue_t quene = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

     

    //任务1

    dispatch_async(quene, ^{

        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);

        NSLog(@"run task 1");

        sleep(1);

        NSLog(@"complete task 1");

        dispatch_semaphore_signal(semaphore);       

    });<br>

    //任务2

    dispatch_async(quene, ^{

        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);

        NSLog(@"run task 2");

        sleep(1);

        NSLog(@"complete task 2");

        dispatch_semaphore_signal(semaphore);       

    });<br>

    //任务3

    dispatch_async(quene, ^{

        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);

        NSLog(@"run task 3");

        sleep(1);

        NSLog(@"complete task 3");

        dispatch_semaphore_signal(semaphore);       

    });   

}

执行结果:

pastedGraphic.png  

总结:由于设定的信号值为2,先执行两个线程,等执行完一个,才会继续执行下一个,保证同一时间执行的线程数不超过2。

这里我们扩展一下,假设我们设定信号值=1

1

dispatch_semaphore_create(1)<br><br>

那么结果就是:

pastedGraphic_1.png

如果设定信号值=3

1

dispatch_semaphore_create(3)<br><br>

那么结果就是: 

pastedGraphic_2.png

其实设定为3,就是不限制线程执行了,因为一共才只有3个线程。

以上只是举的比较简单的例子,在一些特殊场景下,合理利用信号量去控制,能够方便的解决我们的难题哦

4. NSOperationQueue
NSOperationQueue *queue = [[NSOperationQueue alloc]init]; 
// 设置最大线程数
queue.maxConcurrentOperationCount = 5;
// 创建一个A操作

NSBlockOperation *operationA = [NSBlockOperation blockOperationWithBlock:^{

    for (int i = 0; i<10; i++) {
           NSLog(@"i的值是:%d",i);
       }
}];


// 创建一个B操作

NSBlockOperation *operationB = [NSBlockOperation blockOperationWithBlock:^{

     for (int j = 0; j<20; j++) {

          NSLog(@"j的值是:%d",j);

    }

}];

// 添加依赖 B要在A打印完在进行打印 所以是B依赖于A 那么只需要添加如下代码即可完成

[operationB addDependency:operationA];

// 分别加入到队列中

[queue addOperation:operationA];

[queue addOperation:operationB];

//YES会阻塞当前线程
// [queue addOperations:@[operationA, operationB] waitUntilFinished:NO];


作者:一叶倾城乱
链接:https://www.jianshu.com/p/56f4f2cf8cae
來源:简书
简书著作权归作者所有,任何形式的转载都请联系作者获得授权并注明出处。

免责声明:文章转载自《iOS开发之线程组解决请求多个接口数据,完成后,再刷新界面》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇MFC全局函数开局——AfxGetApp解剖VMWare-centOS7 64安装及网络配置下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

30、深入浅出MFC学习笔记,多线程

一、基本概念 1、模块:一段可执行的程序(包括EXE和DLL),其程序代码、数据、资源被加载到内存中,由系统建置一个数据结构来管理它,就是一个模块。这里所说的数据结构,名为Module Database(MDB),其实就是PE格式中的PE表头,可以从WINNT.H 档中找到一个IMAGE_NT_HEADER 结构,就是它。 2、进程:就是一大堆拥有权(o...

delphi 利用 InterlockedCompareExchange 实现主线程维一锁等待

在进行资源锁定时,一般是线程之间进行交互,很少需要在主线程也对资源进行锁定。    不过在一些复杂的业务中,存在子线程与主线程的交互,且一些资源也同步在主线程中使用时,主线程资源锁,就有存在的必要。 假定有一个需求,在SQLITE更新时,需要共同一个更新组件,以减少资源建立与释放及相对应内存回收的需求,则此时的每一个更新,就有先锁定再更新的必要。 废话不多...

Qt线程的简单使用(一)——通过QObject::moveToThread()创建线程

Qt中线程的一种创建方式,就是使用QObject::moveToThread()函数。如下,直接上源代码,可以把费时的任务放到doWork()方法里进行,不阻塞主线程。 1 #ifndef WORKER_H 2 #define WORKER_H 3 4 #include <QObject> 5 6 class Worker : public...

深入理解JVM虚拟机3:垃圾回收器详解

本文转自:https://www.cnblogs.com/snailclimb/p/9086341.html 本系列文章将整理到我在GitHub上的《Java面试指南》仓库,更多精彩内容请到我的仓库里查看 https://github.com/h2pl/Java-Tutorial 喜欢的话麻烦点下Star哈 文章将同步到我的个人博客: www.how2pl...

Java多线程——Condition条件

简介 Condition中的await()方法相当于Object的wait()方法,Condition中的signal()方法相当于Object的notify()方法,Condition中的signalAll()相当于Object的notifyAll()方法。 不同的是,Object中的wait(),notify(),notifyAll()方法是和"同步锁...

java并发编程 线程基础

java并发编程 线程基础 1. java中的多线程 java是天生多线程的,可以通过启动一个main方法,查看main方法启动的同时有多少线程同时启动 public class OnlyMain { public static void main(String[] args) { //虚拟机线程管理接口 Threa...