1. dispatch_semaphore 信号量
信号量是一个整型值并且具有初始计数值,信号量通常支持两个操作:通知和等待。当信号被通知的时候计数值会增加,当信号量在线程上等待的时候,必要的情况下线程会被阻塞掉,直至信号被通知时计数值大于0,然后线程会减少这个计数继续工作。
- GCD中又3个信号量有关的操作:
-
dispatch_semaphore_create
信号量创建 -
dispatch_semaphore_signal
发送通知 -
dispatch_semaphore_wait
信号量等待
dispatch_semaphore_create
创建一个信号量
传入的参数为long,输出一个dispatch_semaphore_t类型且值为value的信号量。
值得注意的是,这里的传入的参数value必须大于或等于0,否则dispatch_semaphore_create会返回NULL
dispatch_semaphore_signal
等待一个信号
这个函数会使传入的信号量dsema的值加1。
返回值为long类型,当返回值为0时表示当前并没有线程等待其处理的信号量,其处理的信号量的值加1即可。
当返回值不为0时,表示其当前有(一个或多个)线程等待其处理的信号量,并且该函数唤醒了一个等待的线程(当线程有优先级时,唤醒优先级最高的线程;否则随机唤醒)。
dispatch_semaphore_wait
等待一个信号
这个函数会使传入的信号量dsema的值减1;
如果dsema信号量的值大于0,该函数所处线程就继续执行下面的语句,并且将信号量的值减1;
如果desema的值为0,那么这个函数就阻塞当前线程等待timeout(注意timeout的类型为dispatch_time_t,
不能直接传入整形或float型数),如果等待的期间desema的值被dispatch_semaphore_signal函数加1了,
且该函数(即dispatch_semaphore_wait)所处线程获得了信号量,那么就继续向下执行并将信号量减1。
如果等待期间没有获取到信号量或者信号量的值一直为0,那么等到timeout时,其所处线程自动执行其后语句
timeout
在设置timeout时,比较有用的两个宏:
DISPATCH_TIME_NOW 表示当前;
DISPATCH_TIME_FOREVER 表示未来;
// 创建信号量
dispatch_semaphore_t sem = dispatch_semaphore_create(0);
// 创建队列
dispatch_queue_t testQueue = dispatch_queue_create("test", NULL);
dispatch_async(testQueue, ^{
for (int i = 0; i < 10; i ++) {
NSLog(@"i的值是----->%d",i);
}
// 发送一个信号
dispatch_semaphore_signal(sem);
});
// 信号量等待
dispatch_semaphore_wait(sem, DISPATCH_TIME_FOREVER);
for (int j = 0; j < 10; j ++) {
NSLog(@"j 的值是----->%d",j);
}
2. dispatch group
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, ^{
// 执行异步任务1
for (int i = 0; i<10; i++) {
NSLog(@"i的值是:%d",i);
}
dispatch_group_leave(group);
});
dispatch_group_enter(group);
dispatch_group_async(group, queue, ^{
// 执行异步任务2
for (int j = 0; j<20; j++) {
NSLog(@"j的值是:%d",j);
}
dispatch_group_leave(group);
});
dispatch_group_notify(group, dispatch_get_main_queue(), ^{
NSLog(@"完成...");
});
对于2个以上的异步请求,请求的回调顺序是不会按照顺序执行的。但是最终都走到了
dispatch_group_notify
里面,对于这个点我也是木有弄明白为啥,有知道的还请指点下!😀😀
3. 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];