Repo-Mirror/craft-engine
9
0
Fork 0
mirror of https://github.com/Xiao-MoMi/craft-engine.git synced 2026-01-04 15:41:38 +00:00
Code Issues Releases Activity

perf(bukkit): 优化 chunks 加载逻辑

Browse Source
This commit is contained in:
jhqwqmc
2025-05-02 00:29:40 +08:00
parent 41a7171623
commit bdaf9d759f
1 changed files with 17 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
bukkit/compatibility/src/main/java/net/momirealms/craftengine/bukkit/compatibility/worldedit/FastAsyncWorldEditDelegate.java
View File

@@ -18,8 +18,12 @@ import net.momirealms.craftengine.bukkit.util.BlockStateUtils;
import net.momirealms.craftengine.core.block.EmptyBlock; import net.momirealms.craftengine.core.block.EmptyBlock;
import net.momirealms.craftengine.core.plugin.CraftEngine; import net.momirealms.craftengine.core.plugin.CraftEngine;
import net.momirealms.craftengine.core.world.ChunkPos; import net.momirealms.craftengine.core.world.ChunkPos;
import net.momirealms.craftengine.core.world.chunk.CEChunk;
import org.bukkit.Bukkit; import org.bukkit.Bukkit;
import java.util.HashSet;
import java.util.Set;
public class FastAsyncWorldEditDelegate extends AbstractDelegateExtent { public class FastAsyncWorldEditDelegate extends AbstractDelegateExtent {
protected FastAsyncWorldEditDelegate(Extent extent) { protected FastAsyncWorldEditDelegate(Extent extent) {
super(extent); super(extent);
@@ -51,6 +55,13 @@ public class FastAsyncWorldEditDelegate extends AbstractDelegateExtent {
private void processBlocks(Region region, Pattern pattern) { private void processBlocks(Region region, Pattern pattern) {
try { try {
var weWorld = region.getWorld();
if (weWorld == null) return;
var world = Bukkit.getWorld(weWorld.getName());
if (world == null) return;
var ceWorld = CraftEngine.instance().worldManager().getWorld(world.getUID());
if (ceWorld == null) return;
Set<CEChunk> needSaveChunks = new HashSet<>();
for (BlockVector3 position : region) { for (BlockVector3 position : region) {
BaseBlock blockState = pattern.applyBlock(position); BaseBlock blockState = pattern.applyBlock(position);
BlockState oldBlockState = getBlock(position); BlockState oldBlockState = getBlock(position);
@@ -62,15 +73,11 @@ public class FastAsyncWorldEditDelegate extends AbstractDelegateExtent {
int stateId = BlockStateUtils.blockDataToId(Bukkit.createBlockData(blockState.getAsString())); int stateId = BlockStateUtils.blockDataToId(Bukkit.createBlockData(blockState.getAsString()));
int oldStateId = BlockStateUtils.blockDataToId(Bukkit.createBlockData(oldBlockState.getAsString())); int oldStateId = BlockStateUtils.blockDataToId(Bukkit.createBlockData(oldBlockState.getAsString()));
if (BlockStateUtils.isVanillaBlock(stateId) && BlockStateUtils.isVanillaBlock(oldStateId)) continue; if (BlockStateUtils.isVanillaBlock(stateId) && BlockStateUtils.isVanillaBlock(oldStateId)) continue;
var weWorld = region.getWorld();
if (weWorld == null) continue;
var world = Bukkit.getWorld(weWorld.getName());
if (world == null) continue;
var ceWorld = CraftEngine.instance().worldManager().getWorld(world.getUID());
if (ceWorld == null) continue;
var ceChunk = ceWorld.getChunkAtIfLoaded(chunkX, chunkZ); var ceChunk = ceWorld.getChunkAtIfLoaded(chunkX, chunkZ);
boolean needSave = false;
if (ceChunk == null) { if (ceChunk == null) {
ceChunk = ceWorld.worldDataStorage().readChunkAt(ceWorld, new ChunkPos(chunkX, chunkZ)); ceChunk = ceWorld.worldDataStorage().readChunkAt(ceWorld, new ChunkPos(chunkX, chunkZ));
needSave = true;
} }
var immutableBlockState = BukkitBlockManager.instance().getImmutableBlockState(stateId); var immutableBlockState = BukkitBlockManager.instance().getImmutableBlockState(stateId);
if (immutableBlockState == null) { if (immutableBlockState == null) {
@@ -78,6 +85,10 @@ public class FastAsyncWorldEditDelegate extends AbstractDelegateExtent {
} else { } else {
ceChunk.setBlockState(blockX, blockY, blockZ, immutableBlockState); ceChunk.setBlockState(blockX, blockY, blockZ, immutableBlockState);
} }
if (needSave) needSaveChunks.add(ceChunk);
}
for (CEChunk ceChunk : needSaveChunks) {
ceWorld.worldDataStorage().writeChunkAt(ceChunk.chunkPos(), ceChunk, true);
} }
} catch (Exception e) { } catch (Exception e) {
CraftEngine.instance().logger().warn("Error when recording FastAsyncWorldEdit operation blocks", e); CraftEngine.instance().logger().warn("Error when recording FastAsyncWorldEdit operation blocks", e);