diff --git a/c2me-base/src/main/java/com/ishland/c2me/base/common/GlobalExecutors.java b/c2me-base/src/main/java/com/ishland/c2me/base/common/GlobalExecutors.java index e19798c0..324a7083 100644 --- a/c2me-base/src/main/java/com/ishland/c2me/base/common/GlobalExecutors.java +++ b/c2me-base/src/main/java/com/ishland/c2me/base/common/GlobalExecutors.java @@ -3,7 +3,6 @@ import com.google.common.util.concurrent.ThreadFactoryBuilder; import com.ishland.c2me.base.ModuleEntryPoint; import com.ishland.c2me.base.common.util.C2MENormalWorkerThreadFactory; -import net.minecraft.util.thread.TaskExecutor; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; @@ -37,6 +36,6 @@ public class GlobalExecutors { new LinkedBlockingQueue<>(), new ThreadFactoryBuilder().setDaemon(true).setNameFormat("c2me-sched").build()); - public static final TaskExecutor asyncSchedulerTaskExecutor = TaskExecutor.create(asyncScheduler, "c2me-sched"); +// public static final TaskExecutor asyncSchedulerTaskExecutor = TaskExecutor.create(asyncScheduler, "c2me-sched"); } diff --git a/c2me-base/src/main/java/com/ishland/c2me/base/mixin/access/ISimpleRandom.java b/c2me-base/src/main/java/com/ishland/c2me/base/mixin/access/ISimpleRandom.java index e1e8c4e0..d250b423 100644 --- a/c2me-base/src/main/java/com/ishland/c2me/base/mixin/access/ISimpleRandom.java +++ b/c2me-base/src/main/java/com/ishland/c2me/base/mixin/access/ISimpleRandom.java @@ -3,6 +3,7 @@ import net.minecraft.util.math.random.LocalRandom; import org.spongepowered.asm.mixin.Mixin; import org.spongepowered.asm.mixin.gen.Accessor; +import org.spongepowered.asm.mixin.gen.Invoker; @Mixin(LocalRandom.class) public interface ISimpleRandom { @@ -10,7 +11,7 @@ public interface ISimpleRandom { @Accessor long getSeed(); - @Accessor - void setSeed(long seed); + @Invoker + void invokeSetSeed(long seed); } diff --git a/c2me-base/src/main/java/com/ishland/c2me/base/mixin/scheduler/MixinThreadedAnvilChunkStorage.java b/c2me-base/src/main/java/com/ishland/c2me/base/mixin/scheduler/MixinThreadedAnvilChunkStorage.java index 1cdd1778..b998fb58 100644 --- a/c2me-base/src/main/java/com/ishland/c2me/base/mixin/scheduler/MixinThreadedAnvilChunkStorage.java +++ b/c2me-base/src/main/java/com/ishland/c2me/base/mixin/scheduler/MixinThreadedAnvilChunkStorage.java @@ -13,7 +13,7 @@ @Mixin(ThreadedAnvilChunkStorage.class) public class MixinThreadedAnvilChunkStorage implements IVanillaChunkManager { - private final SchedulingManager c2me$schedulingManager = new SchedulingManager(GlobalExecutors.asyncSchedulerTaskExecutor::send, GlobalExecutors.GLOBAL_EXECUTOR_PARALLELISM * 2); + private final SchedulingManager c2me$schedulingManager = new SchedulingManager(GlobalExecutors.asyncScheduler, GlobalExecutors.GLOBAL_EXECUTOR_PARALLELISM * 2); @Override public SchedulingManager c2me$getSchedulingManager() { diff --git a/c2me-notickvd/src/main/java/com/ishland/c2me/notickvd/common/NoTickSystem.java b/c2me-notickvd/src/main/java/com/ishland/c2me/notickvd/common/NoTickSystem.java index 17c79683..da68705a 100644 --- a/c2me-notickvd/src/main/java/com/ishland/c2me/notickvd/common/NoTickSystem.java +++ b/c2me-notickvd/src/main/java/com/ishland/c2me/notickvd/common/NoTickSystem.java @@ -26,7 +26,7 @@ public class NoTickSystem { final NoThreadScheduler noThreadScheduler = new NoThreadScheduler(); private final AtomicBoolean isTicking = new AtomicBoolean(); - final Executor executor = GlobalExecutors.asyncSchedulerTaskExecutor::send; + final Executor executor = GlobalExecutors.asyncScheduler; private volatile LongSet noTickOnlyChunksSnapshot = LongSets.EMPTY_SET; private volatile boolean pendingPurge = false; private volatile long age = 0; diff --git a/c2me-opts-worldgen-general/src/main/java/com/ishland/c2me/opts/worldgen/general/common/random_instances/RandomUtils.java b/c2me-opts-worldgen-general/src/main/java/com/ishland/c2me/opts/worldgen/general/common/random_instances/RandomUtils.java index fc088b18..09b88568 100644 --- a/c2me-opts-worldgen-general/src/main/java/com/ishland/c2me/opts/worldgen/general/common/random_instances/RandomUtils.java +++ b/c2me-opts-worldgen-general/src/main/java/com/ishland/c2me/opts/worldgen/general/common/random_instances/RandomUtils.java @@ -28,7 +28,7 @@ public static void derive(RandomSplitter deriver, Random random, int x, int y, i if (deriver instanceof CheckedRandom.Splitter) { final ISimpleRandom random1 = (ISimpleRandom) random; final IAtomicSimpleRandomDeriver deriver1 = (IAtomicSimpleRandomDeriver) deriver; - random1.setSeed(MathHelper.hashCode(x, y, z) ^ deriver1.getSeed()); + random1.invokeSetSeed(MathHelper.hashCode(x, y, z) ^ deriver1.getSeed()); return; } throw new IllegalArgumentException(); diff --git a/c2me-threading-chunkio/src/main/java/com/ishland/c2me/threading/chunkio/mixin/MixinThreadedAnvilChunkStorage.java b/c2me-threading-chunkio/src/main/java/com/ishland/c2me/threading/chunkio/mixin/MixinThreadedAnvilChunkStorage.java index fdde761d..8aa297c3 100644 --- a/c2me-threading-chunkio/src/main/java/com/ishland/c2me/threading/chunkio/mixin/MixinThreadedAnvilChunkStorage.java +++ b/c2me-threading-chunkio/src/main/java/com/ishland/c2me/threading/chunkio/mixin/MixinThreadedAnvilChunkStorage.java @@ -275,7 +275,7 @@ private CompletableFuture> getUpdatedChunkNbtAtAsync(Chunk * @reason skip datafixer if possible */ @Overwrite - private CompletableFuture> getUpdatedChunkNbt(ChunkPos chunkPos) { + public CompletableFuture> getUpdatedChunkNbt(ChunkPos chunkPos) { // return this.getNbt(chunkPos).thenApplyAsync(nbt -> nbt.map(this::updateChunkNbt), Util.getMainWorkerExecutor()); return this.getNbt(chunkPos).thenCompose(nbt -> { if (nbt.isPresent()) {