public abstract class ThreadTaskExecutor<R extends java.lang.Runnable> extends java.lang.Object implements ITaskExecutor<R>, java.util.concurrent.Executor
修飾子 | コンストラクタと説明 |
---|---|
protected |
ThreadTaskExecutor(java.lang.String nameIn) |
修飾子とタイプ | メソッドと説明 |
---|---|
protected abstract boolean |
canRun(R runnable) |
java.util.concurrent.CompletableFuture<java.lang.Void> |
deferTask(java.lang.Runnable taskIn) |
protected void |
drainTasks() |
protected boolean |
driveOne() |
void |
driveUntil(java.util.function.BooleanSupplier isDone)
Drive the executor until the given BooleanSupplier returns true
|
protected void |
dropTasks() |
void |
enqueue(R taskIn) |
void |
execute(java.lang.Runnable p_execute_1_) |
protected abstract java.lang.Thread |
getExecutionThread() |
java.lang.String |
getName() |
int |
getQueueSize() |
boolean |
isOnExecutionThread() |
protected void |
run(R taskIn) |
java.util.concurrent.CompletableFuture<java.lang.Void> |
runAsync(java.lang.Runnable taskIn) |
void |
runImmediately(java.lang.Runnable taskIn) |
protected boolean |
shouldDeferTasks() |
<V> java.util.concurrent.CompletableFuture<V> |
supplyAsync(java.util.function.Supplier<V> supplier) |
protected void |
threadYieldPark() |
protected abstract R |
wrapTask(java.lang.Runnable runnable) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, func_213141_a, inline
protected abstract R wrapTask(java.lang.Runnable runnable)
protected abstract boolean canRun(R runnable)
public boolean isOnExecutionThread()
protected abstract java.lang.Thread getExecutionThread()
protected boolean shouldDeferTasks()
public int getQueueSize()
public java.lang.String getName()
getName
インタフェース内 ITaskExecutor<R extends java.lang.Runnable>
public <V> java.util.concurrent.CompletableFuture<V> supplyAsync(java.util.function.Supplier<V> supplier)
public java.util.concurrent.CompletableFuture<java.lang.Void> deferTask(java.lang.Runnable taskIn)
public java.util.concurrent.CompletableFuture<java.lang.Void> runAsync(java.lang.Runnable taskIn)
public void runImmediately(java.lang.Runnable taskIn)
public void enqueue(R taskIn)
enqueue
インタフェース内 ITaskExecutor<R extends java.lang.Runnable>
public void execute(java.lang.Runnable p_execute_1_)
execute
インタフェース内 java.util.concurrent.Executor
protected void dropTasks()
protected void drainTasks()
protected boolean driveOne()
public void driveUntil(java.util.function.BooleanSupplier isDone)
protected void threadYieldPark()
protected void run(R taskIn)