程序包 net.minecraft.server.level

类 ChunkTaskPriorityQueueSorter

java.lang.Object

net.minecraft.server.level.ChunkTaskPriorityQueueSorter

所有已实现的接口:

AutoCloseable, ChunkHolder.LevelChangeListener

public class ChunkTaskPriorityQueueSorter
extends Object
implements ChunkHolder.LevelChangeListener, AutoCloseable

嵌套类概要

嵌套类

修饰符和类型	类	说明
static final class	ChunkTaskPriorityQueueSorter.Message<T>
static final class	ChunkTaskPriorityQueueSorter.Release

字段概要

字段

修饰符和类型	字段	说明
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

构造器概要

构造器

构造器	说明
ChunkTaskPriorityQueueSorter(List<ProcessorHandle<?>> pQueues, Executor pTask, int pMaxTasks)

方法概要

修饰符和类型	方法	说明
void	close()
String	getDebugStatus()
<T> ProcessorHandle<ChunkTaskPriorityQueueSorter.Message<T>>	getProcessor(ProcessorHandle<T> pProcessor, boolean p_140606_)
private <T> ChunkTaskPriorityQueue<Function<ProcessorHandle<Unit>,T>>	getQueue(ProcessorHandle<T> pProcessor)
ProcessorHandle<ChunkTaskPriorityQueueSorter.Release>	getReleaseProcessor(ProcessorHandle<Runnable> pProcessor)
boolean	hasWork()
static ChunkTaskPriorityQueueSorter.Message<Runnable>	message(Runnable pTask, long pPos, IntSupplier pLevel)
static <T> ChunkTaskPriorityQueueSorter.Message<T>	message(Function<ProcessorHandle<Unit>,T> pTask, long pPos, IntSupplier pLevel)
static ChunkTaskPriorityQueueSorter.Message<Runnable>	message(ChunkHolder pChunkHolder, Runnable pTask)
static <T> ChunkTaskPriorityQueueSorter.Message<T>	message(ChunkHolder pChunkHolder, Function<ProcessorHandle<Unit>,T> pTask)
void	onLevelChange(ChunkPos pChunkPos, 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 pTask, long pPos, boolean pClearQueue)
private <T> void	release(ProcessorHandle<T> pProcessor, long pChunkPos, Runnable p_140572_, boolean pFullClear)
private <T> void	submit(ProcessorHandle<T> pProcessor, Function<ProcessorHandle<Unit>,T> pTask, long pChunkPos, IntSupplier p_140593_, boolean p_140594_)

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

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

字段详细资料

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

构造器详细资料

ChunkTaskPriorityQueueSorter

public ChunkTaskPriorityQueueSorter(List<ProcessorHandle<?>> pQueues,
 Executor pTask,
 int pMaxTasks)

方法详细资料

hasWork

public boolean hasWork()

message

public static <T>
ChunkTaskPriorityQueueSorter.Message<T> message(Function<ProcessorHandle<Unit>,T> pTask,
 long pPos,
 IntSupplier pLevel)

message

public static ChunkTaskPriorityQueueSorter.Message<Runnable> message(Runnable pTask,
 long pPos,
 IntSupplier pLevel)

message

public static ChunkTaskPriorityQueueSorter.Message<Runnable> message(ChunkHolder pChunkHolder,
 Runnable pTask)

message

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

release

public static ChunkTaskPriorityQueueSorter.Release release(Runnable pTask,
 long pPos,
 boolean pClearQueue)

getProcessor

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

getReleaseProcessor

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

onLevelChange

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

指定者:

onLevelChange 在接口中 ChunkHolder.LevelChangeListener

release

private <T> void release(ProcessorHandle<T> pProcessor,
 long pChunkPos,
 Runnable p_140572_,
 boolean pFullClear)

submit

private <T> void submit(ProcessorHandle<T> pProcessor,
 Function<ProcessorHandle<Unit>,T> pTask,
 long pChunkPos,
 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> pProcessor)

getDebugStatus

public String getDebugStatus()

close

public void close()

指定者:

close 在接口中 AutoCloseable