net.minecraft.server.world

public class ChunkTaskPrioritySystem

implements ChunkHolder$LevelUpdateListener, AutoCloseable

acx
net.minecraft.server.level.ChunkTaskPriorityQueueSorter
net.minecraft.class_3900
net.minecraft.server.world.ChunkTaskPrioritySystem
net.minecraft.unmapped.C_gxchrfeu
net.minecraft.src.C_5435_

Field summary

Modifier and TypeField
private static final org.apache.logging.log4j.Logger
a
LOGGER
field_17248
LOGGER
f_ljtohtlz
f_140549_
private final Map<MessageListener<?>, LevelPrioritizedQueue<? extends Function<MessageListener<Unit>, ?>>>
b
queues
field_17249
queues
f_riwndrax
f_140550_
private final Set<MessageListener<?>>
c
sleeping
field_17250
idleActors
f_zwdlmxvd
f_140551_
private final TaskExecutor<TaskQueue$PrioritizedTask>
d
mailbox
field_17251
controlActor
f_qkjtewbe
f_140552_

Constructor summary

ModifierConstructor
public (List<MessageListener<?>> actors, Executor executor, int maxQueues)

Method summary

Modifier and TypeMethod
public static <T> ChunkTaskPrioritySystem$Task<T>
a(Function<auj<ajn>, T> o, long o, IntSupplier arg2)
message(Function<ProcessorHandle<Unit>, T> arg0, long arg1, IntSupplier arg2)
method_34871(Function<class_3906<class_3902>, T> arg0, long arg1, IntSupplier arg2)
createTask(Function<MessageListener<Unit>, T> taskFunction, long pos, IntSupplier lastLevelUpdatedToProvider)
m_qtxwslel(Function<C_brzcgupp<C_djdmkjpx>, T> arg0, long arg1, IntSupplier arg2)
m_143181_(Function<C_450_<C_204_>, T> p_143182_, long p_143183_, IntSupplier arg2)
public static ChunkTaskPrioritySystem$Task<Runnable>
a(Runnable o, long o, IntSupplier arg2)
message(Runnable arg0, long arg1, IntSupplier arg2)
method_17626(Runnable arg0, long arg1, IntSupplier arg2)
createMessage(Runnable task, long pos, IntSupplier lastLevelUpdatedToProvider)
m_ameltmwc(Runnable arg0, long arg1, IntSupplier arg2)
m_140624_(Runnable p_140625_, long p_140626_, IntSupplier arg2)
public static ChunkTaskPrioritySystem$Task<Runnable>
a(acu o, Runnable o)
message(ChunkHolder arg0, Runnable arg1)
method_17629(class_3193 arg0, Runnable arg1)
createMessage(ChunkHolder holder, Runnable task)
m_atnraosj(C_gkderdjo arg0, Runnable arg1)
m_140642_(C_5422_ p_140643_, Runnable p_140644_)
public static <T> ChunkTaskPrioritySystem$Task<T>
a(acu o, Function<auj<ajn>, T> o)
message(ChunkHolder arg0, Function<ProcessorHandle<Unit>, T> arg1)
method_34870(class_3193 arg0, Function<class_3906<class_3902>, T> arg1)
createTask(ChunkHolder holder, Function<MessageListener<Unit>, T> taskFunction)
m_wgiirgzc(C_gkderdjo arg0, Function<C_brzcgupp<C_djdmkjpx>, T> arg1)
m_143156_(C_5422_ p_143157_, Function<C_450_<C_204_>, T> p_143158_)
public static ChunkTaskPrioritySystem$UnblockingMessage
a(Runnable o, long o, boolean arg2)
release(Runnable arg0, long arg1, boolean arg2)
method_17627(Runnable arg0, long arg1, boolean arg2)
createUnblockingMessage(Runnable task, long pos, boolean removeTask)
m_jntswjpq(Runnable arg0, long arg1, boolean arg2)
m_140628_(Runnable p_140629_, long p_140630_, boolean arg2)
public <T> MessageListener<ChunkTaskPrioritySystem$Task<T>>
a(auj<T> o, boolean arg1)
getProcessor(ProcessorHandle<T> arg0, boolean arg1)
method_17622(class_3906<T> arg0, boolean arg1)
createExecutor(MessageListener<T> executor, boolean addBlocker)
m_foettvts(C_brzcgupp<T> arg0, boolean arg1)
m_140604_(C_450_<T> p_140606_, boolean arg1)
public MessageListener<ChunkTaskPrioritySystem$UnblockingMessage>
a(auj<Runnable> arg0)
getReleaseProcessor(ProcessorHandle<Runnable> arg0)
method_17614(class_3906<Runnable> arg0)
createUnblockingExecutor(MessageListener<Runnable> executor)
m_jolejomh(C_brzcgupp<Runnable> arg0)
m_140567_(C_450_<Runnable> arg0)
public void
onLevelChange(bzk o, IntSupplier o, int o, IntConsumer arg3)
onLevelChange(ChunkPos arg0, IntSupplier arg1, int arg2, IntConsumer arg3)
method_17209(class_1923 arg0, IntSupplier arg1, int arg2, IntConsumer arg3)
updateLevel(ChunkPos arg0, IntSupplier arg1, int arg2, IntConsumer arg3)
m_6250_(C_1560_ p_140617_, IntSupplier p_140618_, int p_140619_, IntConsumer arg3)
private <T> void
a(auj<T> o, long o, Runnable arg2, boolean arg3)
release(ProcessorHandle<T> arg0, long arg1, Runnable arg2, boolean arg3)
method_17615(class_3906<T> arg0, long arg1, Runnable arg2, boolean arg3)
removeChunk(MessageListener<T> actor, long chunkPos, Runnable callback, boolean clearTask)
m_dsbbvche(C_brzcgupp<T> arg0, long arg1, Runnable arg2, boolean arg3)
m_140569_(C_450_<T> p_140571_, long p_140572_, Runnable arg2, boolean arg3)
private <T> void
a(auj<T> o, Function<auj<ajn>, T> o, long o, IntSupplier arg3, boolean arg4)
submit(ProcessorHandle<T> arg0, Function<ProcessorHandle<Unit>, T> arg1, long arg2, IntSupplier arg3, boolean arg4)
method_17282(class_3906<T> arg0, Function<class_3906<class_3902>, T> arg1, long arg2, IntSupplier arg3, boolean arg4)
enqueueChunk(MessageListener<T> actor, Function<MessageListener<Unit>, T> task, long chunkPos, IntSupplier lastLevelUpdatedToProvider, boolean addBlocker)
m_opulkykf(C_brzcgupp<T> arg0, Function<C_brzcgupp<C_djdmkjpx>, T> arg1, long arg2, IntSupplier arg3, boolean arg4)
m_140589_(C_450_<T> p_140591_, Function<C_450_<C_204_>, T> p_140592_, long p_140593_, IntSupplier arg3, boolean arg4)
private <T> void
a(acw<Function<auj<ajn>, T>> o, auj<T> arg1)
pollTask(ChunkTaskPriorityQueue<Function<ProcessorHandle<Unit>, T>> arg0, ProcessorHandle<T> arg1)
method_17630(class_3899<Function<class_3906<class_3902>, T>> arg0, class_3906<T> arg1)
enqueueExecution(LevelPrioritizedQueue<Function<MessageListener<Unit>, T>> queue, MessageListener<T> actor)
m_jqtptrbr(C_rrxtgnzj<Function<C_brzcgupp<C_djdmkjpx>, T>> arg0, C_brzcgupp<T> arg1)
m_140645_(C_5434_<Function<C_450_<C_204_>, T>> p_140647_, C_450_<T> arg1)
private <T> LevelPrioritizedQueue<Function<MessageListener<Unit>, T>>
b(auj<T> arg0)
getQueue(ProcessorHandle<T> arg0)
method_17632(class_3906<T> arg0)
getQueue(MessageListener<T> actor)
m_mwkjnnbh(C_brzcgupp<T> arg0)
m_140652_(C_450_<T> arg0)
public String
a()
getDebugStatus()
method_21680()
getDebugString()
m_flztjyku()
m_140558_()
public void
close()
close()
close()