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

Class IOWorker

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable

public class IOWorker
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	IOWorker(File p_63522_, boolean p_63523_, String p_63524_)

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>	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.apache.logging.log4j.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(File p_63522_,
 boolean p_63523_,
 String p_63524_)

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_)

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