-
Notifications
You must be signed in to change notification settings - Fork 1.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
1. add second-cache for revoking db 2. optimize pack trx
- Loading branch information
1 parent
2d88f6e
commit e26b1af
Showing
13 changed files
with
365 additions
and
32 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
45 changes: 45 additions & 0 deletions
45
common/src/main/java/org/tron/common/cache/CacheManager.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,45 @@ | ||
| package org.tron.common.cache; | ||
|
|
||
| import com.google.common.cache.CacheLoader; | ||
| import com.google.common.cache.CacheStats; | ||
| import com.google.common.collect.Maps; | ||
| import java.util.Map; | ||
| import java.util.stream.Collectors; | ||
| import org.tron.common.parameter.CommonParameter; | ||
|
|
||
| public class CacheManager { | ||
|
|
||
| private static final Map<String, TronCache<?, ?>> CACHES = Maps.newConcurrentMap(); | ||
|
|
||
| public static <K, V> TronCache<K, V> allocate(String name) { | ||
| TronCache<K, V> cache = new TronCache<>(name, CommonParameter.getInstance() | ||
| .getStorage().getCacheStrategy(name)); | ||
| CACHES.put(name, cache); | ||
| return cache; | ||
| } | ||
|
|
||
| public static <K, V> TronCache<K, V> allocate(String name, String strategy) { | ||
| TronCache<K, V> cache = new TronCache<>(name, strategy); | ||
| CACHES.put(name, cache); | ||
| return cache; | ||
| } | ||
|
|
||
| public static <K, V> TronCache<K, V> allocate(String name, String strategy, | ||
| CacheLoader<K, V> loader) { | ||
| TronCache<K, V> cache = new TronCache<>(name, strategy, loader); | ||
| CACHES.put(name, cache); | ||
| return cache; | ||
| } | ||
|
|
||
| public static void release(String name) { | ||
| TronCache cache = CACHES.remove(name); | ||
| if (cache != null) { | ||
| cache.invalidateAll(); | ||
| } | ||
| } | ||
|
|
||
| public static Map<String, CacheStats> stats() { | ||
| return CACHES.values().stream().collect(Collectors.toMap(TronCache::getName, TronCache::stats)); | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,66 @@ | ||
| package org.tron.common.cache; | ||
|
|
||
| import com.google.common.base.Objects; | ||
| import com.google.common.cache.Cache; | ||
| import com.google.common.cache.CacheBuilder; | ||
| import com.google.common.cache.CacheLoader; | ||
| import com.google.common.cache.CacheStats; | ||
| import java.util.concurrent.Callable; | ||
| import java.util.concurrent.ExecutionException; | ||
| import lombok.Getter; | ||
|
|
||
| public class TronCache<K, V> { | ||
|
|
||
| private static final int CPUS = Runtime.getRuntime().availableProcessors(); | ||
|
|
||
| @Getter | ||
| private final String name; | ||
| private final Cache<K, V> cache; | ||
|
|
||
| TronCache(String name, String strategy) { | ||
| this.name = name; | ||
| this.cache = CacheBuilder.from(strategy).concurrencyLevel(CPUS).recordStats().build(); | ||
| } | ||
|
|
||
| TronCache(String name, String strategy, CacheLoader<K, V> loader) { | ||
| this.name = name; | ||
| this.cache = CacheBuilder.from(strategy).concurrencyLevel(CPUS).recordStats().build(loader); | ||
| } | ||
|
|
||
| public void put(K k, V v) { | ||
| this.cache.put(k, v); | ||
| } | ||
|
|
||
| public V getIfPresent(K k) { | ||
| return this.cache.getIfPresent(k); | ||
| } | ||
|
|
||
| public V get(K k, Callable<? extends V> loader) throws ExecutionException { | ||
| return this.cache.get(k, loader); | ||
| } | ||
|
|
||
| public CacheStats stats() { | ||
| return this.cache.stats(); | ||
| } | ||
|
|
||
| public void invalidateAll() { | ||
| this.cache.invalidateAll(); | ||
| } | ||
|
|
||
| @Override | ||
| public boolean equals(Object o) { | ||
| if (this == o) { | ||
| return true; | ||
| } | ||
| if (o == null || getClass() != o.getClass()) { | ||
| return false; | ||
| } | ||
| TronCache<?, ?> tronCache = (TronCache<?, ?>) o; | ||
| return Objects.equal(name, tronCache.name); | ||
| } | ||
|
|
||
| @Override | ||
| public int hashCode() { | ||
| return Objects.hashCode(name); | ||
| } | ||
| } |
Oops, something went wrong.