ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-09-06 20:54:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #202 from facebook/batch_insertion

Browse Source 
Batch insertion for reload #200
This commit is contained in:
Nadine Salter 2015-01-07 14:53:15 -08:00
commit bacfcbd24d
1 changed files with 22 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
AsyncDisplayKit/Details/ASDataController.mm
View File

@ -238,7 +238,7 @@ static void *kASDataUpdatingQueueContext = &kASDataUpdatingQueueContext;
INSERT_SECTIONS(_nodes , indexSet, sectionArray);
}];
[self _insertNodes:nodes atIndexPaths:indexPaths];
[self _batchInsertNodes:nodes atIndexPaths:indexPaths];
});
}
@ -278,7 +278,7 @@ static void *kASDataUpdatingQueueContext = &kASDataUpdatingQueueContext;
}];
// reinsert the elements
[self _insertNodes:updatedNodes atIndexPaths:updatedIndexPaths];
[self _batchInsertNodes:updatedNodes atIndexPaths:updatedIndexPaths];
});
}
@ -344,23 +344,29 @@ static void *kASDataUpdatingQueueContext = &kASDataUpdatingQueueContext;
}
}
- (void)insertRowsAtIndexPaths:(NSArray *)indexPaths {
- (void)_batchInsertNodes:(NSArray *)nodes
atIndexPaths:(NSArray *)indexPaths {
NSUInteger blockSize = [[ASDataController class] parallelProcessorCount] * kASDataControllerSizingCountPerProcessor;
// Processing in batches
for (NSUInteger i = 0; i < indexPaths.count; i += blockSize) {
NSRange batchedRange = NSMakeRange(i, MIN(indexPaths.count - i, blockSize));
NSArray *batchedIndexPaths = [indexPaths subarrayWithRange:batchedRange];
NSArray *batchedNodes = [nodes subarrayWithRange:batchedRange];
[self _insertNodes:batchedNodes atIndexPaths:batchedIndexPaths];
}
}
- (void)insertRowsAtIndexPaths:(NSArray *)indexPaths {
// sort indexPath to avoid messing up the index when inserting in several batches
NSArray *sortedIndexPaths = [indexPaths sortedArrayUsingSelector:@selector(compare:)];
// Processing in batches
for (NSUInteger i = 0; i < sortedIndexPaths.count; i += blockSize) {
NSArray *batchedIndexPaths = [sortedIndexPaths subarrayWithRange:NSMakeRange(i, MIN(sortedIndexPaths.count - i, blockSize))];
NSMutableArray *nodes = [NSMutableArray arrayWithCapacity:batchedIndexPaths.count];
[batchedIndexPaths enumerateObjectsUsingBlock:^(NSIndexPath *indexPath, NSUInteger idx, BOOL *stop) {
[nodes addObject:[_dataSource dataController:self nodeAtIndexPath:indexPath]];
}];
[self _insertNodes:nodes atIndexPaths:batchedIndexPaths];
NSMutableArray *nodes = [[NSMutableArray alloc] initWithCapacity:indexPaths.count];
for (NSUInteger i = 0; i < sortedIndexPaths.count; i++) {
[nodes addObject:[_dataSource dataController:self nodeAtIndexPath:sortedIndexPaths[i]]];
}
[self _batchInsertNodes:nodes atIndexPaths:indexPaths];
}
- (void)deleteRowsAtIndexPaths:(NSArray *)indexPaths {
@ -388,7 +394,7 @@ static void *kASDataUpdatingQueueContext = &kASDataUpdatingQueueContext;
DELETE_NODES(_nodes, indexPaths);
}];
[self _insertNodes:nodes atIndexPaths:indexPaths];
[self _batchInsertNodes:nodes atIndexPaths:indexPaths];
});
}
@ -444,7 +450,7 @@ static void *kASDataUpdatingQueueContext = &kASDataUpdatingQueueContext;
}];
[self _insertNodes:updatedNodes atIndexPaths:updatedIndexPaths];
[self _batchInsertNodes:updatedNodes atIndexPaths:updatedIndexPaths];
});
}