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

experimental: read cache for persistent maplets

Browse Source
This commit is contained in:
Eugene Zhuravlev
2012-03-21 13:58:30 +01:00
parent a466a7f200
commit 6e84e21963
2 changed files with 61 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
jps/model/src/org/jetbrains/ether/dependencyView/PersistentMaplet.java
+28 -15
View File
@@ -15,9 +15,11 @@
*/
package org.jetbrains.ether.dependencyView;
import com.intellij.util.containers.SLRUCache;
import com.intellij.util.io.DataExternalizer;
import com.intellij.util.io.KeyDescriptor;
import com.intellij.util.io.PersistentHashMap;
import org.jetbrains.annotations.NotNull;
import java.io.File;
import java.io.IOException;
@@ -33,11 +35,27 @@ import java.util.Map;
* To change this template use File | Settings | File Templates.
*/
public class PersistentMaplet<K, V> implements Maplet<K, V> {
private static final Object NULL_OBJ = new Object();
private static final int CACHE_SIZE = 512;
private final PersistentHashMap<K, V> myMap;
private final SLRUCache<K, Object> myCache;
public PersistentMaplet(final File file, final KeyDescriptor<K> k, final DataExternalizer<V> v) {
try {
myMap = new PersistentHashMap<K, V>(file, k, v);
myCache = new SLRUCache<K, Object>(CACHE_SIZE, CACHE_SIZE) {
@NotNull
@Override
public Object createValue(K key) {
try {
final V v1 = myMap.get(key);
return v1 == null? NULL_OBJ : v1;
}
catch (IOException e) {
throw new RuntimeException(e);
}
}
};
}
catch (IOException e) {
throw new RuntimeException(e);
@@ -56,17 +74,14 @@ public class PersistentMaplet<K, V> implements Maplet<K, V> {
@Override
public V get(final Object key) {
try {
return myMap.get((K)key);
}
catch (IOException e) {
throw new RuntimeException(e);
}
final Object obj = myCache.get((K)key);
return obj == NULL_OBJ? null : (V)obj;
}
@Override
public void put(final K key, final V value) {
try {
myCache.remove(key);
myMap.put(key, value);
}
catch (IOException e) {
@@ -76,20 +91,17 @@ public class PersistentMaplet<K, V> implements Maplet<K, V> {
@Override
public void putAll(final Maplet<K, V> m) {
try {
for (Map.Entry<K, V> e : m.entrySet()) {
myMap.put(e.getKey(), e.getValue());
}
}
catch (IOException e) {
throw new RuntimeException(e);
for (Map.Entry<K, V> e : m.entrySet()) {
put(e.getKey(), e.getValue());
}
}
@Override
public void remove(final Object key) {
try {
myMap.remove((K)key);
final K _key = (K)key;
myCache.remove(_key);
myMap.remove(_key);
}
catch (IOException e) {
throw new RuntimeException(e);
@@ -99,6 +111,7 @@ public class PersistentMaplet<K, V> implements Maplet<K, V> {
@Override
public void close() {
try {
myCache.clear();
myMap.close();
}
catch (IOException e) {
@@ -133,7 +146,7 @@ public class PersistentMaplet<K, V> implements Maplet<K, V> {
try {
for (final K key : myMap.getAllKeysWithExistingMapping()) {
final V value = myMap.get(key);
final V value = get(key);
final Map.Entry<K, V> entry = new Map.Entry<K, V>() {
@Override
jps/model/src/org/jetbrains/ether/dependencyView/PersistentMultiMaplet.java
+33 -14
View File
@@ -15,9 +15,11 @@
*/
package org.jetbrains.ether.dependencyView;
import com.intellij.util.containers.SLRUCache;
import com.intellij.util.io.DataExternalizer;
import com.intellij.util.io.KeyDescriptor;
import com.intellij.util.io.PersistentHashMap;
import org.jetbrains.annotations.NotNull;
import java.io.*;
import java.util.Collection;
@@ -33,16 +35,31 @@ import java.util.Map;
* To change this template use File | Settings | File Templates.
*/
class PersistentMultiMaplet<K, V> implements MultiMaplet<K, V> {
private static final Collection NULL_COLLECTION = Collections.emptySet();
private static final int CACHE_SIZE = 512;
private final PersistentHashMap<K, Collection<V>> myMap;
private final DataExternalizer<V> myValueExternalizer;
private final SLRUCache<K, Collection> myCache;
public PersistentMultiMaplet(final File file,
final KeyDescriptor<K> keyExternalizer,
final DataExternalizer<V> valueExternalizer,
final TransientMultiMaplet.CollectionConstructor<V> collectionFactory) throws IOException {
myValueExternalizer = valueExternalizer;
myMap = new PersistentHashMap<K, Collection<V>>(file, keyExternalizer,
new CollectionDataExternalizer<V>(valueExternalizer, collectionFactory));
myMap = new PersistentHashMap<K, Collection<V>>(file, keyExternalizer, new CollectionDataExternalizer<V>(valueExternalizer, collectionFactory));
myCache = new SLRUCache<K, Collection>(CACHE_SIZE, CACHE_SIZE) {
@NotNull
@Override
public Collection createValue(K key) {
try {
final Collection<V> collection = myMap.get(key);
return collection == null? NULL_COLLECTION : collection;
}
catch (IOException e) {
throw new RuntimeException(e);
}
}
};
}
@@ -58,17 +75,14 @@ class PersistentMultiMaplet<K, V> implements MultiMaplet<K, V> {
@Override
public Collection<V> get(final K key) {
try {
return myMap.get(key);
}
catch (IOException e) {
throw new RuntimeException(e);
}
final Collection<V> collection = myCache.get(key);
return collection == NULL_COLLECTION? null : collection;
}
@Override
public void replace(K key, Collection<V> value) {
try {
myCache.remove(key);
if (value == null) {
myMap.remove(key);
}
@@ -84,6 +98,7 @@ class PersistentMultiMaplet<K, V> implements MultiMaplet<K, V> {
@Override
public void put(final K key, final Collection<V> value) {
try {
myCache.remove(key);
myMap.appendData(key, new PersistentHashMap.ValueDataAppender() {
public void append(DataOutput out) throws IOException {
for (V v : value) {
@@ -105,15 +120,16 @@ class PersistentMultiMaplet<K, V> implements MultiMaplet<K, V> {
@Override
public void removeAll(K key, Collection<V> values) {
try {
final Collection<V> collection = myMap.get(key);
final Collection collection = myCache.get(key);
if (collection != null) {
if (collection != NULL_COLLECTION) {
if (collection.removeAll(values)) {
myCache.remove(key);
if (collection.isEmpty()) {
myMap.remove(key);
}
else {
myMap.put(key, collection);
myMap.put(key, (Collection<V>)collection);
}
}
}
@@ -126,15 +142,16 @@ class PersistentMultiMaplet<K, V> implements MultiMaplet<K, V> {
@Override
public void removeFrom(final K key, final V value) {
try {
final Collection<V> collection = myMap.get(key);
final Collection collection = myCache.get(key);
if (collection != null) {
if (collection != NULL_COLLECTION) {
if (collection.remove(value)) {
myCache.remove(key);
if (collection.isEmpty()) {
myMap.remove(key);
}
else {
myMap.put(key, collection);
myMap.put(key, (Collection<V>)collection);
}
}
}
@@ -147,6 +164,7 @@ class PersistentMultiMaplet<K, V> implements MultiMaplet<K, V> {
@Override
public void remove(final K key) {
try {
myCache.remove(key);
myMap.remove(key);
}
catch (IOException e) {
@@ -180,6 +198,7 @@ class PersistentMultiMaplet<K, V> implements MultiMaplet<K, V> {
@Override
public void close() {
try {
myCache.clear();
myMap.close();
}
catch (IOException e) {