mirrors/Iris
1
0
Fork 0
mirror of https://github.com/VolmitSoftware/Iris.git synced 2025-07-18 02:03:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

3D Cache to caff

Browse Source
This commit is contained in:
cyberpwn 2021-09-21 08:19:24 -04:00
parent 6b62ba1c5b
commit 7755b19abc
3 changed files with 32 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/volmit/iris/Iris.java
View File

@ -450,9 +450,7 @@ public class Iris extends VolmitPlugin implements Listener {
J.s(this::setupPapi);
J.a(ServerConfigurator::configure, 20);
splash();
J.sr(() -> Iris.service(PreservationSVC.class).printCaches(), 20);
if (IrisSettings.get().getStudio().isAutoStartDefaultStudio()) {
Iris.info("Starting up auto Studio!");
try {

4
src/main/java/com/volmit/iris/util/stream/ProceduralStream.java
View File

@ -296,8 +296,8 @@ public interface ProceduralStream<T> extends ProceduralLayer, Interpolated<T> {
return new CachedStream2D<T>(engine, this, maxSize, weak);
}
default ProceduralStream<T> cache3D(int maxSize) {
return new CachedStream3D<T>(this, maxSize);
default ProceduralStream<T> cache3D(Engine engine, int maxSize) {
return new CachedStream3D<T>(engine, this, maxSize);
}
default <V> ProceduralStream<V> convert(Function<T, V> converter) {

40
src/main/java/com/volmit/iris/util/stream/utility/CachedStream3D.java
View File

@ -18,23 +18,26 @@
package com.volmit.iris.util.stream.utility;
import com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap;
import com.volmit.iris.Iris;
import com.volmit.iris.core.service.PreservationSVC;
import com.volmit.iris.engine.framework.Engine;
import com.volmit.iris.engine.framework.MeteredCache;
import com.volmit.iris.util.data.KCache;
import com.volmit.iris.util.math.BlockPosition;
import com.volmit.iris.util.stream.BasicStream;
import com.volmit.iris.util.stream.ProceduralStream;
public class CachedStream3D<T> extends BasicStream<T> implements ProceduralStream<T> {
public class CachedStream3D<T> extends BasicStream<T> implements ProceduralStream<T>, MeteredCache {
private final ProceduralStream<T> stream;
private final ConcurrentLinkedHashMap<BlockPosition, T> cache;
private final KCache<BlockPosition, T> cache;
private final Engine engine;
public CachedStream3D(ProceduralStream<T> stream, int size) {
public CachedStream3D(Engine engine, ProceduralStream<T> stream, int size) {
super();
this.stream = stream;
cache = new ConcurrentLinkedHashMap.Builder<BlockPosition, T>()
.initialCapacity(size)
.maximumWeightedCapacity(size)
.concurrencyLevel(32)
.build();
this.engine = engine;
cache = new KCache<>((k) -> stream.get(k.getX(), k.getY(), k.getZ()), size);
Iris.service(PreservationSVC.class).registerCache(this);
}
@Override
@ -49,11 +52,26 @@ public class CachedStream3D<T> extends BasicStream<T> implements ProceduralStrea
@Override
public T get(double x, double z) {
return cache.computeIfAbsent(new BlockPosition((int) x, -1, (int) z), (k) -> stream.get((int) x, (int) z));
return cache.get(new BlockPosition((int) x, 0, (int) z));
}
@Override
public T get(double x, double y, double z) {
return cache.computeIfAbsent(new BlockPosition((int) x, (int) y, (int) z), (k) -> stream.get((int) x, (int) y, (int) z));
return cache.get(new BlockPosition((int) x, (int) y, (int) z));
}
@Override
public long getSize() {
return cache.getSize();
}
@Override
public long getMaxSize() {
return cache.getMaxSize();
}
@Override
public boolean isClosed() {
return engine.isClosed();
}
}