Browse Source

Merge "Reduce synchronized scope around ConcurrentHashMap"

stable-4.6
Shawn Pearce 8 years ago committed by Gerrit Code Review @ Eclipse.org
parent
commit
a0bac65233
  1. 30
      org.eclipse.jgit/src/org/eclipse/jgit/internal/storage/dfs/DfsBlockCache.java

30
org.eclipse.jgit/src/org/eclipse/jgit/internal/storage/dfs/DfsBlockCache.java

@ -263,20 +263,22 @@ public final class DfsBlockCache {
// TODO This table grows without bound. It needs to clean up // TODO This table grows without bound. It needs to clean up
// entries that aren't in cache anymore, and aren't being used // entries that aren't in cache anymore, and aren't being used
// by a live DfsObjDatabase reference. // by a live DfsObjDatabase reference.
synchronized (packCache) {
DfsPackFile pack = packCache.get(dsc); DfsPackFile pack = packCache.get(dsc);
if (pack != null && pack.invalid()) { if (pack != null && !pack.invalid()) {
packCache.remove(dsc);
pack = null;
}
if (pack == null) {
if (key == null)
key = new DfsPackKey();
pack = new DfsPackFile(this, dsc, key);
packCache.put(dsc, pack);
}
return pack; return pack;
} }
// 'pack' either didn't exist or was invalid. Compute a new
// entry atomically (guaranteed by ConcurrentHashMap).
return packCache.compute(dsc, (k, v) -> {
if (v != null && !v.invalid()) { // valid value added by
return v; // another thread
} else {
return new DfsPackFile(
this, dsc, key != null ? key : new DfsPackKey());
}
});
} }
private int hash(int packHash, long off) { private int hash(int packHash, long off) {
@ -504,9 +506,7 @@ public final class DfsBlockCache {
} }
void remove(DfsPackFile pack) { void remove(DfsPackFile pack) {
synchronized (packCache) { packCache.remove(pack.getPackDescription());
packCache.remove(pack.getPackDescription());
}
} }
private int slot(DfsPackKey pack, long position) { private int slot(DfsPackKey pack, long position) {

Loading…
Cancel
Save