wxa.jpeg
前言:
早就听说 ibireme 这个名字,趁着最近公司没有迭代需求,空闲的时间比较多.于是乎小编就Down了老郭的代码瞧了一段时间.收益多多啊.真心觉得要多读几本书了!!!好了废话言至......
YYDispatchQueuePool 的优点:
1.YYDispatchQueuePool中保存的队列是serialQueue而不是concurrentQueue.
2.YYDispatchQueuePool中的队列是可以复用的.
3.通过队列的优先级来控制任务的执行顺序.
4.队列的数量也是控制在范围1~32.
5.无疑就是代码优雅简洁(呵呵).
问题:为什么要选择serialQueue却不是concurrentQueue?
原因:使用concurrentQueue会开辟线程,那么在项目中大量使用会占用CPU的消耗.CPU 是用时间片轮转来实现线程并发的，尽管 concurrentQueue 能控制线程的优先级，但当大量线程同时创建运行销毁时，这些操作仍然会挤占掉主线程的 CPU 资源.
对源码分析:
//在YYDispatchQueuePool.h中提供了一个快速根据优先级获取队列的C语言接口
extern dispatch_queue_t YYDispatchQueueGetForQOS(NSQualityOfService qos);
这和通过YYDispatchQueuePool对象获得queue不同点就是在与name,其实name在功能实现方面是没有影响的.唯一有用的就是在crash的时候,会提示队列的name.
//禁止用以下两个方式初始化
- (instancetype)init UNAVAILABLE_ATTRIBUTE;
+ (instancetype)new UNAVAILABLE_ATTRIBUTE;
/**
创建队列池
@param name 队列标签
@param queueCount 队列数
@param qos 队列优先级
@return 返回一个队列池子
*/
- (instancetype)initWithName:(nullable NSString *)name queueCount:(NSUInteger)queueCount qos:(NSQualityOfService)qos;
///队列标签
@property (nullable, nonatomic, readonly) NSString *name;
/// 获取队列
- (dispatch_queue_t)queue;
///根据优先级获取队列池(name,queueCount默认配置)
+ (instancetype)defaultPoolForQOS:(NSQualityOfService)qos;
static inline qos_class_t NSQualityOfServiceToQOSClass(NSQualityOfService qos) {
switch (qos) {
case NSQualityOfServiceUserInteractive: return QOS_CLASS_USER_INTERACTIVE;
case NSQualityOfServiceUserInitiated: return QOS_CLASS_USER_INITIATED;
case NSQualityOfServiceUtility: return QOS_CLASS_UTILITY;
case NSQualityOfServiceBackground: return QOS_CLASS_BACKGROUND;
case NSQualityOfServiceDefault: return QOS_CLASS_DEFAULT;
default: return QOS_CLASS_UNSPECIFIED;
}
}
根据qos会获取qos_class_t定义的一个变量,这个变量的作用就是描述队列的优先级.如何描述的呢?
//在这里就可以看到队列是DISPATCH_QUEUE_SERIAL(串行队列)
dispatch_queue_attr_t attr = dispatch_queue_attr_make_with_qos_class(DISPATCH_QUEUE_SERIAL, qosClass, 0);
对attr的第三个参数:相对优先级这里我做了demo测试.demo地址:https://github.com/anjinxiawucha/GCD_Attr.git
感兴趣可以down下来了解下.
// counter自增的也就是说YYDispatchContext变量被创建这个值就会加1,队列能复用和conuter有关系
typedef struct {
const char *name; //queue标签
void **queues; //queue数组
uint32_t queueCount; //队列数量
int32_t counter; //计数器自增的
} YYDispatchContext;
//根据创建YYDispatchContext变量(实质就是缓存池)
static YYDispatchContext *YYDispatchContextCreate(const char *name,
uint32_t queueCount,
NSQualityOfService qos) {
//calloc:在内存的动态存储区中分配n个长度为size的连续空间，函数返回一个指向分配起始地址的指针；如果分配不成功，返回NULL。
// n: Number of elements成员数量 size: Length in bytes of each element每个成员字节长度
YYDispatchContext *context = calloc(1, sizeof(YYDispatchContext));
if (!context) return NULL;
context->queues = calloc(queueCount, sizeof(void *));
if (!context->queues) {
free(context);
return NULL;
}
if ([UIDevice currentDevice].systemVersion.floatValue >= 8.0) {
dispatch_qos_class_t qosClass = NSQualityOfServiceToQOSClass(qos);
for (NSUInteger i = 0; i < queueCount; i++) {
dispatch_queue_attr_t attr = dispatch_queue_attr_make_with_qos_class(DISPATCH_QUEUE_SERIAL, qosClass, 0);
dispatch_queue_t queue = dispatch_queue_create(name, attr);
context->queues[i] = (__bridge_retained void *)(queue);
}
} else {
long identifier = NSQualityOfServiceToDispatchPriority(qos);
for (NSUInteger i = 0; i < queueCount; i++) {
dispatch_queue_t queue = dispatch_queue_create(name, DISPATCH_QUEUE_SERIAL);
dispatch_set_target_queue(queue, dispatch_get_global_queue(identifier, 0));
context->queues[i] = (__bridge_retained void *)(queue);
}
}
context->queueCount = queueCount;
if (name) {
//strdup拷贝(内存分配name)
context->name = strdup(name);
}
return context;
}
释放YYDispatchContext 变量
static void YYDispatchContextRelease(YYDispatchContext *context) {
if (!context) return;
if (context->queues) {
for (NSUInteger i = 0; i < context->queueCount; i++) {
void *queuePointer = context->queues[i];
dispatch_queue_t queue = (__bridge_transfer dispatch_queue_t)(queuePointer);
const char *name = dispatch_queue_get_label(queue);
//防止警告
if (name) strlen(name);
queue = nil;
}
free(context->queues);
context->queues = NULL;
}
if (context->name) free((void *)context->name);
}
//获取queue
static dispatch_queue_t YYDispatchContextGetQueue(YYDispatchContext *context) {
uint32_t counter = (uint32_t)OSAtomicIncrement32(&context->counter);
//counter是自增的.所以队列会被重复使用
void *queue = context->queues[counter % context->queueCount];
return (__bridge dispatch_queue_t)(queue);
}
//根据优先级qos获取对象.
static YYDispatchContext *YYDispatchContextGetForQOS(NSQualityOfService qos) {
static YYDispatchContext *context[5] = {0};
switch (qos) {
case NSQualityOfServiceUserInteractive: {
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
//获取当前项目活跃进程数量 MAX_QUEUE_COUNT = 32
int count = (int)[NSProcessInfo processInfo].activeProcessorCount;
count = count < 1 ? 1 : count > MAX_QUEUE_COUNT ? MAX_QUEUE_COUNT : count;
//这里可以看出队列的数量在一开始就被确定了
context[0] = YYDispatchContextCreate("com.ibireme.yykit.user-interactive", count, qos);
});
return context[0];
} break;
case NSQualityOfServiceUserInitiated: {
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
int count = (int)[NSProcessInfo processInfo].activeProcessorCount;
count = count < 1 ? 1 : count > MAX_QUEUE_COUNT ? MAX_QUEUE_COUNT : count;
context[1] = YYDispatchContextCreate("com.ibireme.yykit.user-initiated", count, qos);
});
return context[1];
} break;
case NSQualityOfServiceUtility: {
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
int count = (int)[NSProcessInfo processInfo].activeProcessorCount;
count = count < 1 ? 1 : count > MAX_QUEUE_COUNT ? MAX_QUEUE_COUNT : count;
context[2] = YYDispatchContextCreate("com.ibireme.yykit.utility", count, qos);
});
return context[2];
} break;
case NSQualityOfServiceBackground: {
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
int count = (int)[NSProcessInfo processInfo].activeProcessorCount;
count = count < 1 ? 1 : count > MAX_QUEUE_COUNT ? MAX_QUEUE_COUNT : count;
context[3] = YYDispatchContextCreate("com.ibireme.yykit.background", count, qos);
});
return context[3];
} break;
case NSQualityOfServiceDefault:
default: {
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
int count = (int)[NSProcessInfo processInfo].activeProcessorCount;
count = count < 1 ? 1 : count > MAX_QUEUE_COUNT ? MAX_QUEUE_COUNT : count;
context[4] = YYDispatchContextCreate("com.ibireme.yykit.default", count, qos);
});
return context[4];
} break;
}
}
最后附上YYKit的地址:https://github.com/ibireme/YYKit. 博客:http://blog.ibireme.com
建议还是看一下博客.有不少干货.
至此对于YYDispatchQueuePool的分析也就差不多了.后期会继续分析YYKit其他的源代码.
就这么走了吗?
就不关注一下吗?
就不订阅一下吗?
下次找不到可咋整呢?
