net.minecraft.util.Scheduler

net.minecraft.util

public abstract class Scheduler<K, T extends Task<K, T>, R>

	acu
	net.minecraft.class_3452
	net.minecraft.util.Scheduler
	net.minecraft.util.Scheduler
	net.minecraft.util.Scheduler

Field summary

Modifier and Type

Field

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

	b
	field_16633
	LOGGER
	field_202856_b
	LOGGER

protected final ExecutorService

	a
	field_16632
	scheduler
	field_202855_a
	schedulerPool

private final ExecutorService

	c
	field_16634
	worker
	field_202857_c
	workerPool

private final AtomicInteger

	d
	field_16635
	workerId
	field_202858_d
	nextWorkerId

private final List<CompletableFuture<R>>

	e
	field_16636
	currentBatch
	field_202859_e
	unbatchedFutures

private CompletableFuture<R>

	f
	field_16637
	prevBatch
	field_202860_f
	field_202860_f

private CompletableFuture<R>

	g
	field_16638
	lastBatch
	field_202861_g
	field_202861_g

private final Supplier<Map<T, CompletableFuture<R>>>

	h
	field_16639
	futuresMaps
	field_202862_h
	field_202862_h

private final Supplier<Map<T, CompletableFuture<Void>>>

	i
	field_16640
	f_73038811
	field_202863_i
	field_202863_i

private final T

	j
	field_16641
	target
	field_202864_j
	targetTaskType

Constructor summary

Modifier	Constructor
public	(String name, int parallelism, T target, Supplier<Map<T, CompletableFuture<R>>> futuresMaps, Supplier<Map<T, CompletableFuture<Void>>> arg4)

Method summary

Modifier and Type

Method

public CompletableFuture<R>

	a(K arg0)
	method_15482(K arg0)
	schedule(K key)
	func_202851_b(K arg0)
	schedule(K key)

public CompletableFuture<R>

	a()
	method_15480()
	collect()
	func_202845_a()
	gather()

protected Scheduler<K, T, R>.a

	b(K arg0)
	method_15493(K arg0)
	getTasks(K key)
	func_201494_a_(K arg0)
	createFutureWrapper(K key)

protected abstract Scheduler<K, T, R>.a

	a(K arg0, boolean arg1)
	method_15486(K arg0, boolean arg1)
	getTasks(K key, boolean create)
	func_212252_a_(K arg0, boolean arg1)
	func_212252_a_(K arg0, boolean arg1)

public void

	b()
	method_15491()
	close()
	func_202854_b()
	shutdown()

protected abstract R

	a(K arg0, T arg1, Map<K, R> arg2)
	method_15484(K arg0, T arg1, Map<K, R> arg2)
	runTask(K key, T task, Map<K, R> results)
	func_201493_a_(K arg0, T arg1, Map<K, R> arg2)
	runTask(K key, T taskType, Map<K, R> providingMap)

public R

	b(K arg0, boolean arg1)
	method_15495(K arg0, boolean arg1)
	getResult(K key, boolean create)
	func_212537_b(K arg0, boolean arg1)
	func_212537_b(K arg0, boolean arg1)

public CompletableFuture<R>

	c()
	method_15496()
	lastBatch()
	func_202846_c()
	getLastFuture()

protected abstract void

	b(K arg0, acu<K, T, R>.acu$a arg1)
	method_15494(K arg0, class_3452<K, T, R>.a arg1)
	release(K key, Scheduler<K, T, R>.a tasks)
	func_205607_b_(K arg0, Scheduler<K, T, R>.a arg1)
	onTaskFinish(K key, Scheduler<K, T, R>.a futureWrapper)

protected abstract Scheduler<K, T, R>.a

	a(K arg0, acu<K, T, R>.acu$a arg1)
	method_15483(K arg0, class_3452<K, T, R>.a arg1)
	retain(K key, Scheduler<K, T, R>.a tasks)
	func_205606_a_(K arg0, Scheduler<K, T, R>.a arg1)
	onTaskStart(K pos, Scheduler<K, T, R>.a futureWrapperIn)