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

calculate editor notifications in a single background thread

Browse Source
This commit is contained in:
peter
2014-05-15 16:20:19 +02:00
parent eae74d23b5
commit a38bfd3e8c
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-impl/src/com/intellij/ui/EditorNotificationsImpl.java
+13 -3
View File
@@ -30,6 +30,7 @@ import com.intellij.openapi.project.DumbService;
import com.intellij.openapi.project.Project;
import com.intellij.openapi.util.Key;
import com.intellij.openapi.vfs.VirtualFile;
import com.intellij.util.ConcurrencyUtil;
import com.intellij.util.containers.ConcurrentWeakHashMap;
import com.intellij.util.containers.ContainerUtil;
import com.intellij.util.messages.MessageBusConnection;
@@ -42,6 +43,7 @@ import org.jetbrains.annotations.Nullable;
import javax.swing.*;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ThreadPoolExecutor;
/**
* @author peter
@@ -49,6 +51,7 @@ import java.util.Map;
public class EditorNotificationsImpl extends EditorNotifications {
private static final ExtensionPointName<Provider> EXTENSION_POINT_NAME = ExtensionPointName.create("com.intellij.editorNotificationProvider");
private final Map<VirtualFile, ProgressIndicator> myCurrentUpdates = new ConcurrentWeakHashMap<VirtualFile, ProgressIndicator>();
private final ThreadPoolExecutor myExecutor = ConcurrencyUtil.newSingleThreadExecutor("EditorNotifications executor");
private final MergingUpdateQueue myUpdateMerger;
public EditorNotificationsImpl(Project project) {
@@ -86,11 +89,18 @@ public class EditorNotificationsImpl extends EditorNotifications {
indicator = new ProgressIndicatorBase();
myCurrentUpdates.put(file, indicator);
ReadTask task = createTask(indicator, file);
final ReadTask task = createTask(indicator, file);
if (ApplicationManager.getApplication().isUnitTestMode()) {
task.computeInReadAction(indicator);
} else {
ProgressIndicatorUtils.scheduleWithWriteActionPriority(indicator, task);
}
else {
final ProgressIndicator indicator1 = indicator;
myExecutor.execute(new Runnable() {
@Override
public void run() {
ProgressIndicatorUtils.runWithWriteActionPriority(indicator1, task);
}
});
}
}
});