public interface ITaskExecutor<Msg>
extends java.lang.AutoCloseable
Modifier and Type | Method and Description |
---|---|
default void |
close() |
void |
enqueue(Msg taskIn) |
default <Source> java.util.concurrent.CompletableFuture<Source> |
func_213141_a(java.util.function.Function<? super ITaskExecutor<Source>,? extends Msg> p_213141_1_) |
java.lang.String |
getName() |
static <Msg> ITaskExecutor<Msg> |
inline(java.lang.String name,
java.util.function.Consumer<Msg> p_213140_1_) |
java.lang.String getName()
void enqueue(Msg taskIn)
default void close()
close
in interface java.lang.AutoCloseable
default <Source> java.util.concurrent.CompletableFuture<Source> func_213141_a(java.util.function.Function<? super ITaskExecutor<Source>,? extends Msg> p_213141_1_)
static <Msg> ITaskExecutor<Msg> inline(java.lang.String name, java.util.function.Consumer<Msg> p_213140_1_)