@InterfaceAudience.Private public final class ProcedureFutureUtil extends Object
CompletableFuture
about the
operation.Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
Modifier | Constructor and Description |
---|---|
private |
ProcedureFutureUtil() |
Modifier and Type | Method and Description |
---|---|
static boolean |
checkFuture(Procedure<?> proc,
Supplier<CompletableFuture<Void>> getFuture,
Consumer<CompletableFuture<Void>> setFuture,
Runnable actionAfterDone) |
static void |
suspend(Procedure<?> proc) |
static void |
suspendIfNecessary(Procedure<?> proc,
Consumer<CompletableFuture<Void>> setFuture,
CompletableFuture<Void> future,
MasterProcedureEnv env,
Runnable actionAfterDone) |
static void |
wakeUp(Procedure<?> proc,
MasterProcedureEnv env) |
private static final org.slf4j.Logger LOG
private ProcedureFutureUtil()
public static boolean checkFuture(Procedure<?> proc, Supplier<CompletableFuture<Void>> getFuture, Consumer<CompletableFuture<Void>> setFuture, Runnable actionAfterDone) throws IOException
IOException
public static void suspendIfNecessary(Procedure<?> proc, Consumer<CompletableFuture<Void>> setFuture, CompletableFuture<Void> future, MasterProcedureEnv env, Runnable actionAfterDone) throws IOException, ProcedureSuspendedException
public static void suspend(Procedure<?> proc) throws ProcedureSuspendedException
ProcedureSuspendedException
public static void wakeUp(Procedure<?> proc, MasterProcedureEnv env)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.