程序包 net.minecraft.world.level.chunk.storage

类 IOWorker

java.lang.Object

net.minecraft.world.level.chunk.storage.IOWorker

所有已实现的接口:

AutoCloseable, ChunkScanAccess

public class IOWorker
extends Object
implements ChunkScanAccess, AutoCloseable

嵌套类概要

嵌套类

修饰符和类型	类	说明
(专用程序包) static class	IOWorker.PendingStore
(专用程序包) static enum	IOWorker.Priority
(专用程序包) static interface	IOWorker.ThrowingSupplier<T>

字段概要

字段

修饰符和类型	字段	说明
private final PriorityConsecutiveExecutor	consecutiveExecutor
private static final org.slf4j.Logger	LOGGER
private final SequencedMap<ChunkPos,IOWorker.PendingStore>	pendingWrites
private static final int	REGION_CACHE_SIZE
private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<CompletableFuture<BitSet>>	regionCacheForBlender
private final AtomicBoolean	shutdownRequested
private final RegionFileStorage	storage

构造器概要

构造器

限定符	构造器	说明
protected	IOWorker(RegionStorageInfo p_335181_, Path p_196930_, boolean p_196931_)

方法概要

修饰符和类型	方法	说明
void	close()
private CompletableFuture<BitSet>	createOldDataForRegion(int p_223490_, int p_223491_)
private CompletableFuture<BitSet>	getOrCreateOldDataForRegion(int p_223464_, int p_223465_)
private boolean	isOldChunk(CompoundTag p_223485_)
boolean	isOldChunkAround(ChunkPos p_223472_, int p_223473_)
CompletableFuture<Optional<CompoundTag>>	loadAsync(ChunkPos p_156588_)
private void	runStore(ChunkPos p_63536_, IOWorker.PendingStore p_63537_)
CompletableFuture<Void>	scanChunk(ChunkPos p_196939_, StreamTagVisitor p_196940_)
RegionStorageInfo	storageInfo()
CompletableFuture<Void>	store(ChunkPos p_363895_, Supplier<CompoundTag> p_367671_)
CompletableFuture<Void>	store(ChunkPos p_63539_, CompoundTag p_63540_)
private void	storePendingChunk()
private <T> CompletableFuture<T>	submitTask(Supplier<T> p_63546_)
private <T> CompletableFuture<T>	submitThrowingTask(IOWorker.ThrowingSupplier<T> p_363182_)
CompletableFuture<Void>	synchronize(boolean p_182499_)
private void	tellStorePending()
private void	waitForShutdown()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

LOGGER

private static final org.slf4j.Logger LOGGER

shutdownRequested

private final AtomicBoolean shutdownRequested

consecutiveExecutor

private final PriorityConsecutiveExecutor consecutiveExecutor

storage

private final RegionFileStorage storage

pendingWrites

private final SequencedMap<ChunkPos,IOWorker.PendingStore> pendingWrites

regionCacheForBlender

private final it.unimi.dsi.fastutil.longs.Long2ObjectLinkedOpenHashMap<CompletableFuture<BitSet>> regionCacheForBlender

REGION_CACHE_SIZE

private static final int REGION_CACHE_SIZE

另请参阅:

• 常量字段值

构造器详细资料

IOWorker

protected IOWorker(RegionStorageInfo p_335181_,
 Path p_196930_,
 boolean p_196931_)

方法详细资料

isOldChunkAround

public boolean isOldChunkAround(ChunkPos p_223472_,
 int p_223473_)

getOrCreateOldDataForRegion

private CompletableFuture<BitSet> getOrCreateOldDataForRegion(int p_223464_,
 int p_223465_)

createOldDataForRegion

private CompletableFuture<BitSet> createOldDataForRegion(int p_223490_,
 int p_223491_)

isOldChunk

private boolean isOldChunk(CompoundTag p_223485_)

store

public CompletableFuture<Void> store(ChunkPos p_63539_,
 @Nullable
 CompoundTag p_63540_)

store

public CompletableFuture<Void> store(ChunkPos p_363895_,
 Supplier<CompoundTag> p_367671_)

loadAsync

public CompletableFuture<Optional<CompoundTag>> loadAsync(ChunkPos p_156588_)

synchronize

public CompletableFuture<Void> synchronize(boolean p_182499_)

scanChunk

public CompletableFuture<Void> scanChunk(ChunkPos p_196939_,
 StreamTagVisitor p_196940_)

指定者:

scanChunk 在接口中 ChunkScanAccess

submitThrowingTask

private <T> CompletableFuture<T> submitThrowingTask(IOWorker.ThrowingSupplier<T> p_363182_)

submitTask

private <T> CompletableFuture<T> submitTask(Supplier<T> p_63546_)

storePendingChunk

private void storePendingChunk()

tellStorePending

private void tellStorePending()

runStore

private void runStore(ChunkPos p_63536_,
 IOWorker.PendingStore p_63537_)

close

public void close()
           throws IOException

指定者:

close 在接口中 AutoCloseable

抛出:

IOException

waitForShutdown

private void waitForShutdown()

storageInfo

public RegionStorageInfo storageInfo()