MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

index update in background: enter dumb mode in all opened projects

Browse Source
This commit is contained in:
Eugene Zhuravlev
2009-09-23 20:39:22 +04:00
parent 40d332d50d
commit b332c3b311
1 changed files with 34 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/lang-impl/src/com/intellij/util/indexing/BackgroundCacheUpdaterRunner.java
+34 -2
View File
@@ -13,6 +13,7 @@ import com.intellij.openapi.progress.ProgressManager;
import com.intellij.openapi.progress.util.ProgressIndicatorBase;
import com.intellij.openapi.project.DumbServiceImpl;
import com.intellij.openapi.project.Project;
import com.intellij.openapi.project.ProjectManager;
import com.intellij.openapi.project.ProjectUtil;
import com.intellij.openapi.util.Key;
import com.intellij.openapi.util.Ref;
@@ -24,6 +25,7 @@ import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable;
import java.util.*;
import java.util.concurrent.CountDownLatch;
/**
* @author Eugene Zhuravlev
@@ -51,6 +53,25 @@ public class BackgroundCacheUpdaterRunner {
}
public void processFiles(final CacheUpdater updater) {
final CountDownLatch latch = new CountDownLatch(myProjectToFileMap.size());
for (Project project : ProjectManager.getInstance().getOpenProjects()) {
if (!myProjectToFileMap.containsKey(project)) {
// if the project is not affected still need to enter dumb mode to keep indices updating in background
// otherwise index access from this project may cause forceUpdate() which will index all the files in the calling thread
DumbServiceImpl.getInstance(project).queueIndexUpdate(new Consumer<ProgressIndicator>() {
public void consume(ProgressIndicator progressIndicator) {
try {
// just wait until update ends and exit dumb mode
latch.await();
}
catch (InterruptedException ignored) {
}
}
});
}
}
for (Map.Entry<Project, Collection<VirtualFile>> entry : myProjectToFileMap.entrySet()) {
final Project project = entry.getKey();
final Collection<VirtualFile> files = entry.getValue();
@@ -85,8 +106,14 @@ public class BackgroundCacheUpdaterRunner {
}
}
finally {
latch.countDown();
queue.clear();
updater.updatingDone();
try {
latch.await();
}
catch (InterruptedException ignored) {
}
}
}
};
@@ -94,8 +121,13 @@ public class BackgroundCacheUpdaterRunner {
DumbServiceImpl.getInstance(project).queueIndexUpdate(action);
}
else {
final ProgressIndicator currentIndicator = ProgressManager.getInstance().getProgressIndicator();
action.consume(currentIndicator != null? currentIndicator : new EmptyProgressIndicator());
try {
final ProgressIndicator currentIndicator = ProgressManager.getInstance().getProgressIndicator();
action.consume(currentIndicator != null? currentIndicator : new EmptyProgressIndicator());
}
finally {
latch.countDown();
}
}
}
}