net.minecraft.world.chunk

Class ChunkTaskPriorityQueueSorter

java.lang.Object

net.minecraft.world.chunk.ChunkTaskPriorityQueueSorter

All Implemented Interfaces:

java.lang.AutoCloseable, ChunkHolder.IListener

public class ChunkTaskPriorityQueueSorter
extends java.lang.Object
implements java.lang.AutoCloseable, ChunkHolder.IListener

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ChunkTaskPriorityQueueSorter.FunctionEntry<T>
static class	ChunkTaskPriorityQueueSorter.RunnableEntry

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Set<ITaskExecutor<?>>	field_219095_c
private static org.apache.logging.log4j.Logger	LOGGER
private java.util.Map<ITaskExecutor<?>,ChunkTaskPriorityQueue<? extends java.util.function.Function<ITaskExecutor<Unit>,?>>>	queues
private DelegatedTaskExecutor<ITaskQueue.RunnableWithPriority>	sorter

Constructor Summary

Constructors

Constructor and Description
ChunkTaskPriorityQueueSorter(java.util.List<ITaskExecutor<?>> p_i50713_1_, java.util.concurrent.Executor p_i50713_2_, int p_i50713_3_)

Method Summary

Modifier and Type	Method and Description
void	close()
void	func_219066_a(ChunkPos pos, java.util.function.IntSupplier p_219066_2_, int p_219066_3_, java.util.function.IntConsumer p_219066_4_)
private <T> void	func_219067_a(ITaskExecutor<T> p_219067_1_, java.util.function.Function<ITaskExecutor<Unit>,T> p_219067_2_, long p_219067_3_, java.util.function.IntSupplier p_219067_5_, boolean p_219067_6_)
static ChunkTaskPriorityQueueSorter.FunctionEntry<java.lang.Runnable>	func_219069_a(java.lang.Runnable p_219069_0_, long pos, java.util.function.IntSupplier p_219069_3_)
static ChunkTaskPriorityQueueSorter.RunnableEntry	func_219073_a(java.lang.Runnable p_219073_0_, long p_219073_1_, boolean p_219073_3_)
private <T> void	func_219074_a(ITaskExecutor<T> p_219074_1_, long p_219074_2_, java.lang.Runnable p_219074_4_, boolean p_219074_5_)
private <T> void	func_219078_a(ChunkTaskPriorityQueue<java.util.function.Function<ITaskExecutor<Unit>,T>> p_219078_1_, ITaskExecutor<T> p_219078_2_)
static ChunkTaskPriorityQueueSorter.FunctionEntry<java.lang.Runnable>	func_219081_a(ChunkHolder p_219081_0_, java.lang.Runnable p_219081_1_)
<T> ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<T>>	func_219087_a(ITaskExecutor<T> p_219087_1_, boolean p_219087_2_)
ITaskExecutor<ChunkTaskPriorityQueueSorter.RunnableEntry>	func_219091_a(ITaskExecutor<java.lang.Runnable> p_219091_1_)
java.lang.String	func_225396_a()
private <T> ChunkTaskPriorityQueue<java.util.function.Function<ITaskExecutor<Unit>,T>>	getQueue(ITaskExecutor<T> p_219068_1_)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.apache.logging.log4j.Logger LOGGER

queues

private final java.util.Map<ITaskExecutor<?>,ChunkTaskPriorityQueue<? extends java.util.function.Function<ITaskExecutor<Unit>,?>>> queues

field_219095_c

private final java.util.Set<ITaskExecutor<?>> field_219095_c

sorter

private final DelegatedTaskExecutor<ITaskQueue.RunnableWithPriority> sorter

Constructor Detail

ChunkTaskPriorityQueueSorter

public ChunkTaskPriorityQueueSorter(java.util.List<ITaskExecutor<?>> p_i50713_1_,
                                    java.util.concurrent.Executor p_i50713_2_,
                                    int p_i50713_3_)

Method Detail

func_219069_a

public static ChunkTaskPriorityQueueSorter.FunctionEntry<java.lang.Runnable> func_219069_a(java.lang.Runnable p_219069_0_,
                                                                                           long pos,
                                                                                           java.util.function.IntSupplier p_219069_3_)

func_219081_a

public static ChunkTaskPriorityQueueSorter.FunctionEntry<java.lang.Runnable> func_219081_a(ChunkHolder p_219081_0_,
                                                                                           java.lang.Runnable p_219081_1_)

func_219073_a

public static ChunkTaskPriorityQueueSorter.RunnableEntry func_219073_a(java.lang.Runnable p_219073_0_,
                                                                       long p_219073_1_,
                                                                       boolean p_219073_3_)

func_219087_a

public <T> ITaskExecutor<ChunkTaskPriorityQueueSorter.FunctionEntry<T>> func_219087_a(ITaskExecutor<T> p_219087_1_,
                                                                                      boolean p_219087_2_)

func_219091_a

public ITaskExecutor<ChunkTaskPriorityQueueSorter.RunnableEntry> func_219091_a(ITaskExecutor<java.lang.Runnable> p_219091_1_)

func_219066_a

public void func_219066_a(ChunkPos pos,
                          java.util.function.IntSupplier p_219066_2_,
                          int p_219066_3_,
                          java.util.function.IntConsumer p_219066_4_)

Specified by:

func_219066_a in interface ChunkHolder.IListener

func_219074_a

private <T> void func_219074_a(ITaskExecutor<T> p_219074_1_,
                               long p_219074_2_,
                               java.lang.Runnable p_219074_4_,
                               boolean p_219074_5_)

func_219067_a

private <T> void func_219067_a(ITaskExecutor<T> p_219067_1_,
                               java.util.function.Function<ITaskExecutor<Unit>,T> p_219067_2_,
                               long p_219067_3_,
                               java.util.function.IntSupplier p_219067_5_,
                               boolean p_219067_6_)

func_219078_a

private <T> void func_219078_a(ChunkTaskPriorityQueue<java.util.function.Function<ITaskExecutor<Unit>,T>> p_219078_1_,
                               ITaskExecutor<T> p_219078_2_)

getQueue

private <T> ChunkTaskPriorityQueue<java.util.function.Function<ITaskExecutor<Unit>,T>> getQueue(ITaskExecutor<T> p_219068_1_)

func_225396_a

public java.lang.String func_225396_a()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable