iOS Swift中并发执行任务优化Google邮件批量获取性能

我之前在处理大规模Gmail邮件批量获取时，也遇到过单Batch请求处理数千个ID时的性能瓶颈，结合Google Objective-C客户端库的特性，给你几个实用的并发优化思路：

一、拆分大数组为小批次并发执行Batch请求 #

Google的Batch API虽然支持批量请求，但当请求数量达到数千级时，单Batch的响应时间会急剧增加，还容易因为请求体积过大触发超时或限流。建议把消息ID数组拆分成小批次（比如每组50-100个ID），然后并发发起这些小Batch请求，既能提升整体速度，也能降低单请求失败的影响范围。

代码示例： #

// 1. 拆分消息ID数组为小批次
NSInteger optimalBatchSize = 50; // 可根据实际测试调整这个数值
NSMutableArray<NSArray<NSString*> *> *smallBatches = [NSMutableArray array];
NSArray<NSString*> *allMessageIDs = /* 你的数千个消息ID数组 */;

for (NSInteger i = 0; i < allMessageIDs.count; i += optimalBatchSize) {
    NSInteger endIdx = MIN(i + optimalBatchSize, allMessageIDs.count);
    NSArray<NSString*> *batch = [allMessageIDs subarrayWithRange:NSMakeRange(i, endIdx - i)];
    [smallBatches addObject:batch];
}

// 2. 用Dispatch Group管理并发Batch请求
dispatch_group_t batchGroup = dispatch_group_create();
// 控制并发队列的优先级和并发数，避免过度请求
dispatch_queue_t concurrentQueue = dispatch_queue_create("com.yourapp.gmail.batch.concurrent", DISPATCH_QUEUE_CONCURRENT);
dispatch_set_target_queue(concurrentQueue, dispatch_get_global_queue(QOS_CLASS_USER_INITIATED, 0));

for (NSArray<NSString*> *batch in smallBatches) {
    dispatch_group_enter(batchGroup);
    dispatch_async(concurrentQueue, ^{
        // 创建当前批次的Batch Query
        GTLRBatchQuery *batchQuery = [GTLRBatchQuery batchQuery];
        for (NSString *msgID in batch) {
            GTLRGmailQuery_MessagesGet *msgQuery = [GTLRGmailQuery_MessagesGet queryWithUserId:@"me" messageId:msgID];
            msgQuery.format = @"full"; // 根据需求设置邮件格式（full/metadata/minimal）
            // 给单条请求添加回调处理
            [batchQuery addQuery:msgQuery completionHandler:^(GTLRServiceTicket *ticket, id object, NSError *error) {
                if (error) {
                    // 处理单条消息获取失败的情况，比如记录日志或标记待重试
                    NSLog(@"获取消息 %@ 失败: %@", msgID, error.localizedDescription);
                } else {
                    GTLRGmailMessage *message = (GTLRGmailMessage *)object;
                    // 在这里处理拿到的邮件内容，比如解析、存储等
                }
            }];
        }
        
        // 执行当前Batch请求
        [self.gmailService executeQuery:batchQuery completionHandler:^(GTLRServiceTicket *ticket, id object, NSError *error) {
            if (error) {
                NSLog(@"Batch请求失败: %@", error.localizedDescription);
                // 可选：对整个失败的Batch进行重试（注意避免无限循环）
            }
            dispatch_group_leave(batchGroup);
        }];
    });
}

// 等待所有并发Batch请求完成
dispatch_group_wait(batchGroup, DISPATCH_TIME_FOREVER);
// 所有请求完成后的后续逻辑，比如通知UI更新、统计结果等

二、单消息请求并发（非Batch） #

如果拆分Batch后性能仍达不到预期，可以尝试直接对每个消息ID发起独立的messagesGet请求，用队列控制并发数，避免触发Google API的限流机制。这种方式的优势是单请求失败不会影响其他请求，容错性更高。

代码示例（用NSOperationQueue控制并发）： #

NSOperationQueue *gmailRequestQueue = [[NSOperationQueue alloc] init];
gmailRequestQueue.maxConcurrentOperationCount = 8; // 控制并发数，建议5-10之间，避免被限流

for (NSString *msgID in allMessageIDs) {
    NSBlockOperation *operation = [NSBlockOperation blockOperationWithBlock:^{
        GTLRGmailQuery_MessagesGet *query = [GTLRGmailQuery_MessagesGet queryWithUserId:@"me" messageId:msgID];
        query.format = @"full";
        
        // 同步执行请求（因为在NSOperation的block里，同步不会阻塞主线程）
        GTLRServiceTicket *ticket = [self.gmailService executeQuery:query completionHandler:^(GTLRServiceTicket *ticket, id object, NSError *error) {
            if (error) {
                NSLog(@"获取消息 %@ 失败: %@", msgID, error.localizedDescription);
            } else {
                GTLRGmailMessage *message = (GTLRGmailMessage *)object;
                // 处理邮件内容
            }
        }];
        // 可选：设置超时时间
        ticket.timeoutInterval = 30;
    }];
    [gmailRequestQueue addOperation:operation];
}

// 监听队列完成事件
[gmailRequestQueue addObserver:self forKeyPath:@"operations" options:NSKeyValueObservingOptionNew context:nil];
// 在observeValueForKeyPath里判断队列是否为空，完成后续处理

关键注意事项 #

• 限流与重试：Google API有请求配额和限流机制，并发过多会返回429错误。建议开启客户端库的重试功能（self.gmailService.retryEnabled = YES），或者自己实现指数退避重试逻辑。
• 内存管理：处理数千封邮件时，要注意及时释放不需要的对象（比如解析后的邮件内容），避免内存占用过高触发警告。
• 配额检查：提前确认你的Gmail API配额是否足够支撑并发请求，必要时在Google Cloud Console申请提升配额。

内容的提问来源于stack exchange，提问作者user9364391