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

earlier LowMemoryWatcher notifications

Browse Source
This commit is contained in:
peter
2012-05-31 17:44:31 +02:00
parent 4eabf0d145
commit 998f5cce1c
4 changed files with 42 additions and 94 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jps/jps-builders/src/org/jetbrains/jps/incremental/IncProjectBuilder.java
+2 -8
View File
@@ -1,6 +1,5 @@
package org.jetbrains.jps.incremental;
import com.intellij.openapi.Forceable;
import com.intellij.openapi.diagnostic.Logger;
import com.intellij.openapi.util.LowMemoryWatcher;
import com.intellij.openapi.util.Pair;
@@ -93,14 +92,9 @@ public class IncProjectBuilder {
public void build(CompileScope scope, final boolean isMake, final boolean isProjectRebuild, boolean forceCleanCaches)
throws RebuildRequestedException {
final LowMemoryWatcher memWatcher = LowMemoryWatcher.register(new Forceable() {
final LowMemoryWatcher memWatcher = LowMemoryWatcher.register(new Runnable() {
@Override
public boolean isDirty() {
return true; // always perform flush when not enough memory
}
@Override
public void force() {
public void run() {
myProjectDescriptor.dataManager.flush(false);
myTimestamps.force();
}
platform/lang-impl/src/com/intellij/semantic/SemServiceImpl.java
+3 -2
View File
@@ -89,8 +89,9 @@ public class SemServiceImpl extends SemService{
myInheritors = cacheKeyHierarchy(myProducers.keySet());
final LowMemoryWatcher watcher = LowMemoryWatcher.register(new LowMemoryWatcher.ForceableAdapter() {
public void force() {
final LowMemoryWatcher watcher = LowMemoryWatcher.register(new Runnable() {
@Override
public void run() {
clearCache();
//System.out.println("SemService cache flushed");
}
platform/util/src/com/intellij/openapi/util/LowMemoryWatcher.java
+35 -82
View File
@@ -15,16 +15,16 @@
*/
package com.intellij.openapi.util;
import com.intellij.openapi.Forceable;
import com.intellij.openapi.diagnostic.Logger;
import com.intellij.reference.SoftReference;
import com.intellij.util.containers.ContainerUtil;
import com.intellij.util.containers.WeakList;
import java.lang.ref.ReferenceQueue;
import java.lang.ref.WeakReference;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import javax.management.Notification;
import javax.management.NotificationEmitter;
import javax.management.NotificationListener;
import java.lang.management.ManagementFactory;
import java.lang.management.MemoryNotificationInfo;
import java.lang.management.MemoryPoolMXBean;
import java.lang.management.MemoryType;
/**
* @author Eugene Zhuravlev
@@ -33,97 +33,50 @@ import java.util.Set;
public class LowMemoryWatcher {
private static final long MEM_THRESHOLD = 5 /*MB*/ * 1024 * 1024;
public abstract static class ForceableAdapter implements Forceable {
public boolean isDirty() {
return true;
}
}
private static final Logger LOG = Logger.getInstance("#com.intellij.openapi.util.LowMemoryWatcher");
private static final ReferenceQueue<Object> ourRefQueue = new ReferenceQueue<Object>();
@SuppressWarnings({"FieldCanBeLocal"})
private static SoftReference<Object> ourRef;
private static final List<WeakReference<LowMemoryWatcher>> ourInstances = ContainerUtil.createEmptyCOWList();
private static final WeakList<LowMemoryWatcher> ourInstances = new WeakList<LowMemoryWatcher>();
private final Forceable myForceable;
private final Runnable myRunnable;
static {
final Thread thread = new Thread("LowMemoryWatcher") {
boolean shouldCleanup = false;
public void run() {
updateRef();
final Set<WeakReference<LowMemoryWatcher>> toRemove = new HashSet<WeakReference<LowMemoryWatcher>>();
while (true) {
try {
ourRefQueue.remove();
updateRef();
if (!shouldCleanup) {
final Runtime runtime = Runtime.getRuntime();
shouldCleanup = runtime.maxMemory() - runtime.totalMemory() <= MEM_THRESHOLD;
for (MemoryPoolMXBean bean : ManagementFactory.getMemoryPoolMXBeans()) {
if (bean.getType() == MemoryType.HEAP && bean.isUsageThresholdSupported()) {
long threshold = bean.getUsage().getMax() - MEM_THRESHOLD;
if (threshold > 0) {
bean.setUsageThreshold(threshold);
bean.setCollectionUsageThreshold(threshold);
}
}
}
((NotificationEmitter)ManagementFactory.getMemoryMXBean()).addNotificationListener(new NotificationListener() {
public void handleNotification(Notification n, Object hb) {
if (MemoryNotificationInfo.MEMORY_THRESHOLD_EXCEEDED.equals(n.getType()) || MemoryNotificationInfo.MEMORY_COLLECTION_THRESHOLD_EXCEEDED.equals(n.getType())) {
System.out.println(n.getType());
for (LowMemoryWatcher watcher : ourInstances) {
try {
watcher.myRunnable.run();
}
for (WeakReference<LowMemoryWatcher> instanceRef : ourInstances) {
final LowMemoryWatcher watcher = instanceRef.get();
if (watcher == null) {
toRemove.add(instanceRef);
}
else {
if (shouldCleanup) {
try {
watcher.doCleanup();
}
catch (Throwable e) {
LOG.info(e);
}
}
}
catch (Throwable e) {
LOG.info(e);
}
if (!toRemove.isEmpty()) {
ourInstances.removeAll(toRemove);
toRemove.clear();
}
}
catch (InterruptedException ignored) {
}
}
}
};
thread.setPriority(Thread.NORM_PRIORITY - 1);
thread.setDaemon(true);
thread.start();
}, null, null);
}
public static LowMemoryWatcher register(Forceable forceable) {
return new LowMemoryWatcher(forceable);
public static LowMemoryWatcher register(Runnable runnable) {
return new LowMemoryWatcher(runnable);
}
private LowMemoryWatcher(Forceable forceable) {
myForceable = forceable;
updateRef();
ourInstances.add(new WeakReference<LowMemoryWatcher>(this));
private LowMemoryWatcher(Runnable runnable) {
myRunnable = runnable;
ourInstances.add(this);
}
public void stop() {
for (WeakReference<LowMemoryWatcher> ref : ourInstances) {
if (ref.get() == this) {
ourInstances.remove(ref);
break;
}
}
ourInstances.remove(this);
}
private void doCleanup() {
if (myForceable.isDirty()) {
myForceable.force();
}
}
private static void updateRef() {
ourRef = new SoftReference<Object>(new Object(), ourRefQueue);
}
}
platform/util/src/com/intellij/util/io/PersistentHashMap.java
+2 -2
View File
@@ -128,9 +128,9 @@ public class PersistentHashMap<Key, Value> extends PersistentEnumeratorDelegate<
return myCanReEnumerate ? size + POSITIVE_VALUE_SHIFT < Integer.MAX_VALUE: false;
}
private final LowMemoryWatcher myAppendCacheFlusher = LowMemoryWatcher.register(new LowMemoryWatcher.ForceableAdapter() {
private final LowMemoryWatcher myAppendCacheFlusher = LowMemoryWatcher.register(new Runnable() {
@Override
public void force() {
public void run() {
//System.out.println("Flushing caches: " + myFile.getPath());
dropMemoryCaches();
}