net.minecraft.util.concurrent

Class DelegatedTaskExecutor<T>

java.lang.Object

net.minecraft.util.concurrent.DelegatedTaskExecutor<T>

All Implemented Interfaces:

java.lang.AutoCloseable, java.lang.Runnable, ITaskExecutor<T>

public class DelegatedTaskExecutor<T>
extends java.lang.Object
implements ITaskExecutor<T>, java.lang.AutoCloseable, java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.Executor	delegate
private java.util.concurrent.atomic.AtomicInteger	flags
private static org.apache.logging.log4j.Logger	LOGGER
private java.lang.String	name
ITaskQueue<? super T,? extends java.lang.Runnable>	queue

Constructor Summary

Constructors

Constructor and Description
DelegatedTaskExecutor(ITaskQueue<? super T,? extends java.lang.Runnable> queueIn, java.util.concurrent.Executor delegateIn, java.lang.String nameIn)

Method Summary

Modifier and Type	Method and Description
private void	clearActive()
void	close()
static DelegatedTaskExecutor<java.lang.Runnable>	create(java.util.concurrent.Executor p_213144_0_, java.lang.String p_213144_1_)
private boolean	driveOne()
private int	driveWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction p_213145_1_)
void	enqueue(T taskIn)
java.lang.String	getName()
private boolean	isActive()
private void	reschedule()
void	run()
private boolean	setActive()
private boolean	shouldSchedule()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.minecraft.util.concurrent.ITaskExecutor

func_213141_a, inline

Field Detail

LOGGER

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

flags

private final java.util.concurrent.atomic.AtomicInteger flags

queue

public final ITaskQueue<? super T,? extends java.lang.Runnable> queue

delegate

private final java.util.concurrent.Executor delegate

name

private final java.lang.String name

Constructor Detail

DelegatedTaskExecutor

public DelegatedTaskExecutor(ITaskQueue<? super T,? extends java.lang.Runnable> queueIn,
                             java.util.concurrent.Executor delegateIn,
                             java.lang.String nameIn)

Method Detail

create

public static DelegatedTaskExecutor<java.lang.Runnable> create(java.util.concurrent.Executor p_213144_0_,
                                                               java.lang.String p_213144_1_)

setActive

private boolean setActive()

clearActive

private void clearActive()

shouldSchedule

private boolean shouldSchedule()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface ITaskExecutor<T>

isActive

private boolean isActive()

driveOne

private boolean driveOne()

run

public void run()

Specified by:

run in interface java.lang.Runnable

enqueue

public void enqueue(T taskIn)

Specified by:

enqueue in interface ITaskExecutor<T>

reschedule

private void reschedule()

driveWhile

private int driveWhile(it.unimi.dsi.fastutil.ints.Int2BooleanFunction p_213145_1_)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getName

public java.lang.String getName()

Specified by:

getName in interface ITaskExecutor<T>