Package net.minecraft.world.level.chunk.storage

Class IOWorker

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, ChunkScanAccess

public class IOWorker
extends Object
implements ChunkScanAccess, AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	IOWorker.PendingStore
(package private) static enum	IOWorker.Priority

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOGGER
private final ProcessorMailbox<StrictQueue.IntRunnable>	mailbox
private final Map<ChunkPos,IOWorker.PendingStore>	pendingWrites
private final AtomicBoolean	shutdownRequested
private final RegionFileStorage	storage

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	IOWorker(Path p_196930_, boolean p_196931_, String p_196932_)

Method Summary

Modifier and Type	Method	Description
void	close()
CompoundTag	load(ChunkPos p_63534_)
protected CompletableFuture<CompoundTag>	loadAsync(ChunkPos p_156588_)
private void	runStore(ChunkPos p_63536_, IOWorker.PendingStore p_63537_)
CompletableFuture<Void>	scanChunk(ChunkPos p_196939_, StreamTagVisitor p_196940_)
CompletableFuture<Void>	store(ChunkPos p_63539_, CompoundTag p_63540_)
private void	storePendingChunk()
private <T> CompletableFuture<T>	submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> p_63546_)
CompletableFuture<Void>	synchronize(boolean p_182499_)
private void	tellStorePending()

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

shutdownRequested

private final AtomicBoolean shutdownRequested

mailbox

private final ProcessorMailbox<StrictQueue.IntRunnable> mailbox

storage

private final RegionFileStorage storage

pendingWrites

private final Map<ChunkPos,IOWorker.PendingStore> pendingWrites

Constructor Details

IOWorker

protected IOWorker(Path p_196930_,
 boolean p_196931_,
 String p_196932_)

Method Details

store

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

load

@Nullable
public CompoundTag load(ChunkPos p_63534_)
                 throws IOException

Throws:

IOException

loadAsync

protected CompletableFuture<CompoundTag> loadAsync(ChunkPos p_156588_)

synchronize

public CompletableFuture<Void> synchronize(boolean p_182499_)

scanChunk

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

Specified by:

scanChunk in interface ChunkScanAccess

submitTask

private <T> CompletableFuture<T> submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> 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

Specified by:

close in interface AutoCloseable

Throws:

IOException