Package org.processmining.specpp.orchestra

Class ExecutionEnvironment

java.lang.Object

org.processmining.specpp.orchestra.ExecutionEnvironment

All Implemented Interfaces:

java.lang.AutoCloseable, Joinable

public class ExecutionEnvironment
extends java.lang.Object
implements Joinable, java.lang.AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ExecutionEnvironment.EnvironmentSettings
static class	ExecutionEnvironment.ExecutionEvironmentThread
static class	ExecutionEnvironment.SPECppExecution<C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result>

Constructor Summary

Constructors

Constructor	Description
ExecutionEnvironment()
ExecutionEnvironment(int threadCount)
ExecutionEnvironment(ExecutionEnvironment.EnvironmentSettings envs)

Method Summary

Modifier and Type	Method	Description
<C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> com.google.common.util.concurrent.ListenableFuture<?>	addCompletionCallback(ExecutionEnvironment.SPECppExecution<C,I,R,F> execution, java.util.function.Consumer<ExecutionEnvironment.SPECppExecution<C,I,R,F>> callback)
<C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> void	addLightweightCompletionCallback(ExecutionEnvironment.SPECppExecution<C,I,R,F> execution, java.util.function.Consumer<ExecutionEnvironment.SPECppExecution<C,I,R,F>> callback)
<C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> com.google.common.util.concurrent.ListenableFuture<?>	addTimeLimitedCompletionCallback(ExecutionEnvironment.SPECppExecution<C,I,R,F> execution, java.util.function.Consumer<ExecutionEnvironment.SPECppExecution<C,I,R,F>> callback, java.time.Duration timeLimit)
void	close()
<C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> ExecutionEnvironment.SPECppExecution<C,I,R,F>	execute(SPECpp<C,I,R,F> specpp, ExecutionParameters executionParameters)
void	join()
static <C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> ExecutionEnvironment.SPECppExecution<C,I,R,F>	oneshotExecution(SPECpp<C,I,R,F> specpp, ExecutionParameters executionParameters)
java.lang.String	threadPoolInfo()
static ExecutionEnvironment.ExecutionEvironmentThread	wrap(java.util.function.Consumer<ExecutionEnvironment> user, java.lang.Runnable finallyClause)
static ExecutionEnvironment.ExecutionEvironmentThread	wrap(ExecutionEnvironment.EnvironmentSettings envs, java.util.function.Consumer<ExecutionEnvironment> user, java.lang.Runnable finallyClause)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionEnvironment

public ExecutionEnvironment()

ExecutionEnvironment

public ExecutionEnvironment(int threadCount)

ExecutionEnvironment

public ExecutionEnvironment(ExecutionEnvironment.EnvironmentSettings envs)

Method Detail

join

public void join()
          throws java.lang.InterruptedException

Specified by:

join in interface Joinable

Throws:

java.lang.InterruptedException

close

public void close()
           throws java.lang.InterruptedException

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.InterruptedException

wrap

public static ExecutionEnvironment.ExecutionEvironmentThread wrap(java.util.function.Consumer<ExecutionEnvironment> user,
                                                                  java.lang.Runnable finallyClause)

wrap

public static ExecutionEnvironment.ExecutionEvironmentThread wrap(ExecutionEnvironment.EnvironmentSettings envs,
                                                                  java.util.function.Consumer<ExecutionEnvironment> user,
                                                                  java.lang.Runnable finallyClause)

threadPoolInfo

public java.lang.String threadPoolInfo()

oneshotExecution

public static <C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> ExecutionEnvironment.SPECppExecution<C,I,R,F> oneshotExecution(SPECpp<C,I,R,F> specpp,
                                                                                                                                                                                                           ExecutionParameters executionParameters)

addTimeLimitedCompletionCallback

public <C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> com.google.common.util.concurrent.ListenableFuture<?> addTimeLimitedCompletionCallback(ExecutionEnvironment.SPECppExecution<C,I,R,F> execution,
                                                                                                                                                                                                          java.util.function.Consumer<ExecutionEnvironment.SPECppExecution<C,I,R,F>> callback,
                                                                                                                                                                                                          java.time.Duration timeLimit)

addCompletionCallback

public <C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> com.google.common.util.concurrent.ListenableFuture<?> addCompletionCallback(ExecutionEnvironment.SPECppExecution<C,I,R,F> execution,
                                                                                                                                                                                               java.util.function.Consumer<ExecutionEnvironment.SPECppExecution<C,I,R,F>> callback)

addLightweightCompletionCallback

public <C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> void addLightweightCompletionCallback(ExecutionEnvironment.SPECppExecution<C,I,R,F> execution,
                                                                                                                                                         java.util.function.Consumer<ExecutionEnvironment.SPECppExecution<C,I,R,F>> callback)

execute

public <C extends Candidate,I extends CompositionComponent<C>,R extends Result,F extends Result> ExecutionEnvironment.SPECppExecution<C,I,R,F> execute(SPECpp<C,I,R,F> specpp,
                                                                                                                                                                                           ExecutionParameters executionParameters)