Tinker with interleaveBoundedCyclicList
This commit is contained in:
@@ -51,12 +51,12 @@ void interleaveBoundedCyclicList(void **jobs, bool (*step)(void *), int count) {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
constexpr int kConcurrent = 16;
|
constexpr int kConcurrent = 32;
|
||||||
void *inProgress[kConcurrent];
|
void *inProgress[kConcurrent];
|
||||||
int nextJob[kConcurrent];
|
int nextJob[kConcurrent];
|
||||||
|
|
||||||
int started = std::min(kConcurrent, count);
|
int started = std::min(kConcurrent, count);
|
||||||
for (int i = 0; i < kConcurrent; i++) {
|
for (int i = 0; i < started; i++) {
|
||||||
inProgress[i] = jobs[i];
|
inProgress[i] = jobs[i];
|
||||||
nextJob[i] = i + 1;
|
nextJob[i] = i + 1;
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user