Orchestrator.activate(CompletableFuture[] futures) that accepts only a single CompletableFuture
argument and returns that same argument after having activated it.Orchestrator.activate(long, CompletableFuture[]) with TimeUnit option.Orchestrator.activate(CompletableFuture[]) that will timeout according to the TimeoutStrategy
* in effect.Orchestrator.task(TaskInterface).Orchestrator.activate(CompletableFuture[]) that waits for all of its arguments to complete
(successfully or exceptionally).Orchestrator.activateAndWait(long, CompletableFuture[]) with TimeUnit option.Orchestrator.activateAndWait(CompletableFuture[]) that will timeout according to the TimeoutStrategy
in effect.Orchestrator.activateAndWait(CompletableFuture[]) that returns a typed result from typed input.Orchestrator.activateAndWait(long timeout, List) with TimeUnit option.Orchestrator.activateAndWait(long timeout, CompletableFuture[]) that returns a typed result
matching the supplied typed input.Orchestrator.activateAsReady(long, List, TriConsumer) without a timeout.Orchestrator.activateAsReady(long, List, TriConsumer) TimeUnit option.Orchestrator.activateFuture(long, List) with TimeUnit option.Orchestrator.activateFuture(List) that will timeout according to the TimeoutStrategy in effectGlobalOrchestratorConfig.Config.updateConfigurationOn(Orchestrator, Object).TaskRunner.executeTaskMethod(TaskRun, Thread, Object), but in the parent thread.Orchestrator.cond(CompletableFuture, CompletableFuture) with an additional boolean argument
indicating whether to proactively activate thenFuture at the same time as condition.Orchestrator.cond(CompletableFuture, CompletableFuture, CompletableFuture) with additional boolean
arguments indicating whether to proactively activate thenFuture and/or elseFuture when
condition is activated.Orchestrator allow CompletableFuture tasks to
be created from lambda expressions that do not return a value.TaskRun.run()
to complete the invocation (unless there is some reason to prevent it, but then the implementation
must take responsibility to ensure the all CompletableFuture return values are completed).TaskNotStartedException on any CompletableFuture that was prevented
from starting in that manner.Orchestrator.create(String) or Orchestrator.setName(String).CommonConfig.firstInterceptWith(TaskRunner),
CommonConfig.lastInterceptWith(TaskRunner), or for Orchestrators as set from current global settings.Orchestrator.activate(CompletableFuture[]) (directly or
through an operation on a CompletableFuture return value).TimeoutStrategy.PREVENT_NEW.Light
annotation.Orchestrator created in this thread
will be applied and recorded for later retrieval.TaskInterface method is called directly on a user POJO
rather than the wrapper return from Orchestrator.task(TaskInterface),
when the user POJO has not overridden such methods (which is usually the case).CommonConfig.setTimeoutMs(long) after calculating the millisecond duration from the supplied arguments.Orchestrator allow CompletableFuture tasks to
be created from lambda expressions that supply a return value.TaskRunners.TaskRunners.CompletableFuture.get(long, TimeUnit).BiConsumer.Copyright © 2021. All rights reserved.