File tree Expand file tree Collapse file tree 1 file changed +10
-8
lines changed Expand file tree Collapse file tree 1 file changed +10
-8
lines changed Original file line number Diff line number Diff line change @@ -341,15 +341,17 @@ static void multiThreadedPageIn(const DeferredFiles &deferred) {
341
341
std::unique_ptr<DeferredFiles>(new DeferredFiles (deferred)));
342
342
if (!running)
343
343
running = new std::thread ([&]() {
344
- mutex.lock ();
345
- while (!queue.empty ()) {
346
- const DeferredFiles &deferred = *queue.front ();
347
- mutex.unlock ();
348
- multiThreadedPageInBackground (deferred);
349
- mutex.lock ();
350
- queue.pop_front ();
344
+ while (true ) {
345
+ mutex.lock ();
346
+ if (queue.empty ) {
347
+ mutex.unlock ();
348
+ break ;
349
+ }
350
+ DeferredFiles deferred (*queue.front ());
351
+ queue.pop_front ();
352
+ mutex.unlock ();
353
+ multiThreadedPageInBackground (deferred);
351
354
}
352
- mutex.unlock ();
353
355
});
354
356
}
355
357
mutex.unlock ();
You can’t perform that action at this time.
0 commit comments