盒子
盒子
文章目录
  1. 通过添加线程依赖和信号量结合实现一个复杂界面请求多个接口时按指定顺序执行

多个接口顺序执行的处理方法

通过添加线程依赖和信号量结合实现一个复杂界面请求多个接口时按指定顺序执行

线程依赖关系和GCD的信号量相结合来实现

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
-(void)dispatchAllRequest{
// 利用线程依赖关系测试
__weak typeof (self)weakSelf =self;

NSBlockOperation * operation1 = [NSBlockOperation blockOperationWithBlock:^{
[weakSelf requestA];

}];
NSBlockOperation * operation2 = [NSBlockOperation blockOperationWithBlock:^{
[weakSelf requestB];

}];
NSBlockOperation * operation3 = [NSBlockOperation blockOperationWithBlock:^{
[weakSelf requestC];

}];
[operation2 addDependency:operation1];
[operation3 addDependency:operation2];
NSOperationQueue * queue = [[NSOperationQueue alloc]init];
[queue addOperations:@[operation1,operation2,operation3] waitUntilFinished:NO];
}
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
-(void)requestA{

//创建信号量并设置计数默认为0
dispatch_semaphore_t sema = dispatch_semaphore_create(0);

AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];;
manager.responseSerializer = [AFHTTPResponseSerializer serializer];
manager.responseSerializer.acceptableContentTypes = [NSSet setWithObjects:@"application/json", @"text/json", @"text/javascript",@"text/html",nil];
[manager GET:@"http://qr.bookln.cn/qr.html?crcode=110000000F00000000000000B3ZX1CEC" parameters:nil progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) {

dispatch_semaphore_signal(sema);
NSLog(@"正在执行A");

} failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
////计数+1操作

dispatch_semaphore_signal(sema);
NSLog(@"执行错误A");

}];

NSLog(@"正在刷新A");
//若计数为0则一直等待
dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
NSLog(@"已经刷新A");
}
-(void)requestB{
//创建信号量并设置计数默认为0
dispatch_semaphore_t sema = dispatch_semaphore_create(0);

AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];;
manager.responseSerializer = [AFHTTPResponseSerializer serializer];
manager.responseSerializer.acceptableContentTypes = [NSSet setWithObjects:@"application/json", @"text/json", @"text/javascript",@"text/html",nil];
[manager GET:@"http://qr.bookln.cn/qr.html?crcode=110000000F00000000000000B3ZX1CEC" parameters:nil progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) {
dispatch_semaphore_signal(sema);
NSLog(@"正在执行B");

} failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
////计数+1操作

dispatch_semaphore_signal(sema);
NSLog(@"执行错误B");

}];

NSLog(@"正在刷新B");
//若计数为0则一直等待
dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
NSLog(@"已经刷新B");

}
-(void)requestC{

//创建信号量并设置计数默认为0
dispatch_semaphore_t sema = dispatch_semaphore_create(0);

AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];;
manager.responseSerializer = [AFHTTPResponseSerializer serializer];
manager.responseSerializer.acceptableContentTypes = [NSSet setWithObjects:@"application/json", @"text/json", @"text/javascript",@"text/html",nil];
[manager GET:@"http://qr.bookln.cn/qr.html?crcode=110000000F00000000000000B3ZX1CEC" parameters:nil progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) {
dispatch_semaphore_signal(sema);
NSLog(@"正在执行C");

} failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
////计数+1操作

dispatch_semaphore_signal(sema);
NSLog(@"执行错误C");

}];

NSLog(@"正在刷新C");
//若计数为0则一直等待
dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
NSLog(@"已经刷新C");
}

附:

关于信号量
信号量:就是一种可用来控制访问资源的数量的标识,设定了一个信号量,在线程访问之前,加上信号量的处理,则可告知系统按照我们指定的信号量数量来执行多个线程。
其实,这有点类似锁机制了,只不过信号量都是系统帮助我们处理了,我们只需要在执行线程之前,设定一个信号量值,并且在使用时,加上信号量处理方法就行了。
信号量为0则阻塞线程,大于0则不会阻塞。因此我们可以通过改变信号量的值,来控制是否阻塞线程,从而达到线程同步。
在GCD中有三个函数是semaphore的操作,分别是:
  dispatch_semaphore_create   创建一个semaphore
    dispatch_semaphore_signal   发送一个信号
      dispatch_semaphore_wait    等待信号
        简单的介绍一下这三个函数,第一个函数有一个整形的参数,我们可以理解为信号的总量,dispatch_semaphore_signal是发送一个信号,自然会让信号总量加1,dispatch_semaphore_wait等待信号,当信号总量少于0的时候就会一直等待,否则就可以正常的执行,并让信号总量-1,根据这样的原理,我们便可以快速的创建一个并发控制来同步任务和有限资源访问控制。
        
        
        
        
         
           
           > 创建队列的两种方式
           1.主队列
           凡是添加到主队列的任务(NSOperation),都会放在主线程执行
           NSOperationQueue queue = [NSOperationQueue mainQueue];
           2.其他队列(非主队列)
           添加到这种队列的任务(NSOperation),就会自动放到子现场中执行
           同时包含了:串形,并发功能
           NSOperationQueue
queue = [[NSOperationQueue alloc] init];
           以下是系统API提供的添加任务到队列中的方式
           - (void)addOperation:(NSOperation )op;
           - (void)addOperations:(NSArray<NSOperation
> )ops waitUntilFinished:(BOOL)wait NS_AVAILABLE(10_6, 4_0);
           以下API就是添加线程依赖关系
           - (void)addDependency:(NSOperation
)op;

支持一下
扫一扫,支持ddSoul