Package net.minecraft.world.chunk.storage

Class IOWorker

java.lang.Object

net.minecraft.world.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.Entry
(package private) static enum	IOWorker.Priority

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.logging.log4j.Logger	LOGGER
private final DelegatedTaskExecutor<ITaskQueue.RunnableWithPriority>	mailbox
private final Map<ChunkPos,IOWorker.Entry>	pendingWrites
private final AtomicBoolean	shutdownRequested
private final RegionFileCache	storage

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	IOWorker(File p_i231890_1_, boolean p_i231890_2_, String p_i231890_3_)

Method Summary

Modifier and Type	Method	Description
void	close()
CompoundNBT	load(ChunkPos p_227090_1_)
private void	runStore(ChunkPos p_227091_1_, IOWorker.Entry p_227091_2_)
CompletableFuture<Void>	store(ChunkPos p_227093_1_, CompoundNBT p_227093_2_)
private void	storePendingChunk()
private <T> CompletableFuture<T>	submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> p_235975_1_)
CompletableFuture<Void>	synchronize()
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 DelegatedTaskExecutor<ITaskQueue.RunnableWithPriority> mailbox

storage

private final RegionFileCache storage

pendingWrites

private final Map<ChunkPos,IOWorker.Entry> pendingWrites

Constructor Details

IOWorker

protected IOWorker(File p_i231890_1_,
 boolean p_i231890_2_,
 String p_i231890_3_)

Method Details

store

public CompletableFuture<Void> store(ChunkPos p_227093_1_,
 CompoundNBT p_227093_2_)

load

@Nullable
public CompoundNBT load(ChunkPos p_227090_1_)
                 throws IOException

Throws:

IOException

synchronize

public CompletableFuture<Void> synchronize()

submitTask

private <T> CompletableFuture<T> submitTask(Supplier<com.mojang.datafixers.util.Either<T,Exception>> p_235975_1_)

storePendingChunk

private void storePendingChunk()

tellStorePending

private void tellStorePending()

runStore

private void runStore(ChunkPos p_227091_1_,
 IOWorker.Entry p_227091_2_)

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException