hardcoresushi/libcryfs
1
0
Fork 0
Code Issues Pull Requests Releases Activity

Increase parallelity level for cache flushing

Browse Source
This commit is contained in:
Sebastian Meßmer 2015-10-15 05:45:49 +02:00
parent 92d0d073a5
commit 9a27cea138
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
implementations/caching/cache/Cache.h vendored
View File

@ -126,7 +126,8 @@ void Cache<Key, Value, MAX_ENTRIES>::_deleteOldEntriesParallel() {
template<class Key, class Value, uint32_t MAX_ENTRIES>
void Cache<Key, Value, MAX_ENTRIES>::_deleteMatchingEntriesAtBeginningParallel(std::function<bool (const CacheEntry<Key, Value> &)> matches) {
unsigned int numThreads = std::max(1u, std::thread::hardware_concurrency());
// Twice the number of cores, so we use full CPU even if half the threads are doing I/O
unsigned int numThreads = 2 * std::max(1u, std::thread::hardware_concurrency());
std::vector<std::future<void>> waitHandles;
for (unsigned int i = 0; i < numThreads; ++i) {
waitHandles.push_back(std::async(std::launch::async, [this, matches] {