net.minecraft.util

Class Scheduler<K,T extends ITaskType<K,T>,R>

java.lang.Object

net.minecraft.util.Scheduler<K,T,R>

Direct Known Subclasses:

ProtoChunkScheduler

public abstract class Scheduler<K,T extends ITaskType<K,T>,R>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Scheduler.FutureWrapper

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.ExecutorService	schedulerPool

Constructor Summary

Constructors

Constructor and Description
Scheduler(java.lang.String name, int concurrency, T p_i48724_3_, java.util.function.Supplier<java.util.Map<T,java.util.concurrent.CompletableFuture<R>>> p_i48724_4_, java.util.function.Supplier<java.util.Map<T,java.util.concurrent.CompletableFuture<java.lang.Void>>> p_i48724_5_)

Method Summary

Modifier and Type	Method and Description
protected Scheduler.FutureWrapper	createFutureWrapper(K key)
protected abstract Scheduler.FutureWrapper	func_212252_a_(K p_212252_1_, boolean p_212252_2_)
R	func_212537_b(K p_212537_1_, boolean p_212537_2_)
java.util.concurrent.CompletableFuture<R>	gather()
java.util.concurrent.CompletableFuture<R>	getLastFuture()
protected abstract void	onTaskFinish(K key, Scheduler.FutureWrapper futureWrapper)
protected abstract Scheduler.FutureWrapper	onTaskStart(K pos, Scheduler.FutureWrapper futureWrapperIn)
protected abstract R	runTask(K key, T taskType, java.util.Map<K,R> providingMap)
java.util.concurrent.CompletableFuture<R>	schedule(K key)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

schedulerPool

protected final java.util.concurrent.ExecutorService schedulerPool

Constructor Detail

Scheduler

public Scheduler(java.lang.String name,
                 int concurrency,
                 T p_i48724_3_,
                 java.util.function.Supplier<java.util.Map<T,java.util.concurrent.CompletableFuture<R>>> p_i48724_4_,
                 java.util.function.Supplier<java.util.Map<T,java.util.concurrent.CompletableFuture<java.lang.Void>>> p_i48724_5_)

Method Detail

schedule

public java.util.concurrent.CompletableFuture<R> schedule(K key)

gather

public java.util.concurrent.CompletableFuture<R> gather()

createFutureWrapper

protected Scheduler.FutureWrapper createFutureWrapper(K key)

func_212252_a_

@Nullable
protected abstract Scheduler.FutureWrapper func_212252_a_(K p_212252_1_,
                                                                    boolean p_212252_2_)

shutdown

public void shutdown()
              throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

runTask

protected abstract R runTask(K key,
                             T taskType,
                             java.util.Map<K,R> providingMap)

func_212537_b

@Nullable
public R func_212537_b(K p_212537_1_,
                                 boolean p_212537_2_)

getLastFuture

public java.util.concurrent.CompletableFuture<R> getLastFuture()

onTaskFinish

protected abstract void onTaskFinish(K key,
                                     Scheduler.FutureWrapper futureWrapper)

onTaskStart

protected abstract Scheduler.FutureWrapper onTaskStart(K pos,
                                                       Scheduler.FutureWrapper futureWrapperIn)