Package net.minecraft.server.level

Class ChunkTaskPriorityQueueSorter

java.lang.Object

net.minecraft.server.level.ChunkTaskPriorityQueueSorter

All Implemented Interfaces:

AutoCloseable, ChunkHolder.LevelChangeListener

public class ChunkTaskPriorityQueueSorter
extends Object
implements ChunkHolder.LevelChangeListener, AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ChunkTaskPriorityQueueSorter.Message<T>
static final class	ChunkTaskPriorityQueueSorter.Release

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOGGER
private final ProcessorMailbox<StrictQueue.IntRunnable>	mailbox
private final Map<ProcessorHandle<?>,ChunkTaskPriorityQueue<? extends Function<ProcessorHandle<Unit>,?>>>	queues
private final Set<ProcessorHandle<?>>	sleeping

Constructor Summary

Constructors

Constructor	Description
ChunkTaskPriorityQueueSorter(List<ProcessorHandle<?>> p_140555_, Executor p_140556_, int p_140557_)

Method Summary

Modifier and Type	Method	Description
void	close()
String	getDebugStatus()
<T> ProcessorHandle<ChunkTaskPriorityQueueSorter.Message<T>>	getProcessor(ProcessorHandle<T> p_140605_, boolean p_140606_)
private <T> ChunkTaskPriorityQueue<Function<ProcessorHandle<Unit>,T>>	getQueue(ProcessorHandle<T> p_140653_)
ProcessorHandle<ChunkTaskPriorityQueueSorter.Release>	getReleaseProcessor(ProcessorHandle<Runnable> p_140568_)
boolean	hasWork()
static ChunkTaskPriorityQueueSorter.Message<Runnable>	message(Runnable p_140625_, long p_140626_, IntSupplier p_140627_)
static <T> ChunkTaskPriorityQueueSorter.Message<T>	message(Function<ProcessorHandle<Unit>,T> p_143182_, long p_143183_, IntSupplier p_143184_)
static ChunkTaskPriorityQueueSorter.Message<Runnable>	message(ChunkHolder p_140643_, Runnable p_140644_)
static <T> ChunkTaskPriorityQueueSorter.Message<T>	message(ChunkHolder p_143157_, Function<ProcessorHandle<Unit>,T> p_143158_)
void	onLevelChange(ChunkPos p_140616_, IntSupplier p_140617_, int p_140618_, IntConsumer p_140619_)
private <T> void	pollTask(ChunkTaskPriorityQueue<Function<ProcessorHandle<Unit>,T>> p_140646_, ProcessorHandle<T> p_140647_)
static ChunkTaskPriorityQueueSorter.Release	release(Runnable p_140629_, long p_140630_, boolean p_140631_)
private <T> void	release(ProcessorHandle<T> p_140570_, long p_140571_, Runnable p_140572_, boolean p_140573_)
private <T> void	submit(ProcessorHandle<T> p_140590_, Function<ProcessorHandle<Unit>,T> p_140591_, long p_140592_, IntSupplier p_140593_, boolean p_140594_)

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

queues

private final Map<ProcessorHandle<?>,ChunkTaskPriorityQueue<? extends Function<ProcessorHandle<Unit>,?>>> queues

sleeping

private final Set<ProcessorHandle<?>> sleeping

mailbox

private final ProcessorMailbox<StrictQueue.IntRunnable> mailbox

Constructor Details

ChunkTaskPriorityQueueSorter

public ChunkTaskPriorityQueueSorter(List<ProcessorHandle<?>> p_140555_,
 Executor p_140556_,
 int p_140557_)

Method Details

hasWork

public boolean hasWork()

message

public static <T>
ChunkTaskPriorityQueueSorter.Message<T> message(Function<ProcessorHandle<Unit>,T> p_143182_,
 long p_143183_,
 IntSupplier p_143184_)

message

public static ChunkTaskPriorityQueueSorter.Message<Runnable> message(Runnable p_140625_,
 long p_140626_,
 IntSupplier p_140627_)

message

public static ChunkTaskPriorityQueueSorter.Message<Runnable> message(ChunkHolder p_140643_,
 Runnable p_140644_)

message

public static <T>
ChunkTaskPriorityQueueSorter.Message<T> message(ChunkHolder p_143157_,
 Function<ProcessorHandle<Unit>,T> p_143158_)

release

public static ChunkTaskPriorityQueueSorter.Release release(Runnable p_140629_,
 long p_140630_,
 boolean p_140631_)

getProcessor

public <T>
ProcessorHandle<ChunkTaskPriorityQueueSorter.Message<T>> getProcessor(ProcessorHandle<T> p_140605_,
 boolean p_140606_)

getReleaseProcessor

public ProcessorHandle<ChunkTaskPriorityQueueSorter.Release> getReleaseProcessor(ProcessorHandle<Runnable> p_140568_)

onLevelChange

public void onLevelChange(ChunkPos p_140616_,
 IntSupplier p_140617_,
 int p_140618_,
 IntConsumer p_140619_)

Specified by:

onLevelChange in interface ChunkHolder.LevelChangeListener

release

private <T> void release(ProcessorHandle<T> p_140570_,
 long p_140571_,
 Runnable p_140572_,
 boolean p_140573_)

submit

private <T> void submit(ProcessorHandle<T> p_140590_,
 Function<ProcessorHandle<Unit>,T> p_140591_,
 long p_140592_,
 IntSupplier p_140593_,
 boolean p_140594_)

pollTask

private <T> void pollTask(ChunkTaskPriorityQueue<Function<ProcessorHandle<Unit>,T>> p_140646_,
 ProcessorHandle<T> p_140647_)

getQueue

private <T>
ChunkTaskPriorityQueue<Function<ProcessorHandle<Unit>,T>> getQueue(ProcessorHandle<T> p_140653_)

getDebugStatus

public String getDebugStatus()

close

public void close()

Specified by:

close in interface AutoCloseable