使用信号量(dispatch_semaphore_t)来实现,AFN回调执行完成之后再执行后面的代码
什么是信号量?
- 为了防止出现因多个程序同时访问一个共享资源而引发的一系列问题,我们需要一种方法,它可以通过生成并使用令牌来授权,在任一时刻只能有一个执行线程访问代码的临界区域.临界区域是指执行数据更新的代码需要独占式地执行.而信号量就可以提供这样的一种访问机制,让一个临界区同一时间只有一个线程在访问它,也就是说信号量是用来调协进程对共享资源的访问的.
- 信号量就是一个资源计数器,对信号量有两个操作来达到互斥,分别是P和V操作.一般情况是这样进行临界访问或互斥访问的:设信号量值为1,当一个进程1运行是,使用资源,进行P操作,即对信号量值减1,也就是资源数少了1个.这是信号量值为0.系统中规定当信号量值为0是,必须等待,知道信号量值不为零才能继续操作.这时如果进程2想要运行,那么也必须进行P操作,但是此时信号量为0,所以无法减1,即不能P操作,也就阻塞.这样就到到了进程1排他访问.当进程1运行结束后,释放资源,进行V操作.资源数重新加1,这是信号量的值变为1,这时进程2发现资源数不为0,信号量能进行P操作了,立即执行P操作.信号量值又变为0,次数进程2咱有资源,排他访问资源,这就是信号量来控制互斥的原理.
- 在iOS开发中,我们可以通过
dispatch方法来设置信号量,实现某些需求.
在当前项目中,我需要实现一个功能,那就是发送请求之前判断token是否过期了,如果过期,那么需要刷新token,然后再发送请求.那么我必须保证发送请求之前,token必须刷新完成,即刷新token的请求的回调必须执行完之后才能执行发送请求的代码.
//刷新token
- (void)reloadToken
{
NSLog(@"1");
NSLog(@"%@",[NSThread currentThread]);
//先创建一个semaphore
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);
//拼接路径
NSString *url=[NSString stringWithFormat:@"%@%@%@",BASE_URL,TOKEN_REFRESH_URL,[LTools cacheForKey:User_id]];
AFHTTPSessionManager *manager = [AFHTTPSessionManager manager];
//为请求的回调开启线程,不然会形成死锁,代码永远都不会执行了
manager.completionQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
//添加token到请求头
[manager.requestSerializer setValue:[LTools cacheForKey:TokenNew] forHTTPHeaderField:@"oldToken"];
//发送请求
[manager GET:url parameters:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nonnull responseObject)
{
//存储新的token
NSString *newToken = responseObject[@"data"][@"token"];
[LTools cache:newToken ForKey:TokenNew];
NSLog(@"3-1");
NSLog(@"3-1%@",[NSThread currentThread]);
//发出已完成的信号
dispatch_semaphore_signal(semaphore);
}
failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error)
{
//如果请求失败,那么取消登录状态,删除个人数据
[LTools storage:NO ForKey:LoginState];
NSUserDefaults *userDefaults = [NSUserDefaults standardUserDefaults];
//删除所有用户数据
[userDefaults removeObjectForKey:User_id];
[userDefaults removeObjectForKey:User_headimg];
[userDefaults removeObjectForKey:User_mobile];
[userDefaults removeObjectForKey:User_nickName];
[userDefaults removeObjectForKey:User_isPayPassword];
[userDefaults removeObjectForKey:User_CarId];
[userDefaults removeObjectForKey:User_CarLogo];
[userDefaults removeObjectForKey:User_isWeChat];
[userDefaults removeObjectForKey:User_isQQ];
[userDefaults removeObjectForKey:TokenNew];
[userDefaults removeObjectForKey:User_gender];
[userDefaults removeObjectForKey:User_carBrand];
[userDefaults removeObjectForKey:User_RecommendCode];
NSLog(@"3-2");
NSLog(@"3-2%@",[NSThread currentThread]);
//发出已完成的信号
dispatch_semaphore_signal(semaphore);
}];
NSLog(@"2");
NSLog(@"%@",[NSThread currentThread]);
//等待执行，不会占用资源
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
}
