Backport: Refactor join handling

- Backporting #235 #237
- Refactor how join is handled
- Add new StateListener for listening entry/exit per State.
- Transition is now passed to next guy from a join state.
- A lot of changes in core machine/factory/executor to support
  this new join handling.
- Fixes #261
This commit is contained in:
Janne Valkealahti
2016-09-28 15:40:26 +01:00
parent fccc109661
commit 5a779c8858
17 changed files with 1021 additions and 81 deletions

View File

@@ -61,6 +61,7 @@ import org.springframework.statemachine.state.ExitPseudoState;
import org.springframework.statemachine.state.ForkPseudoState;
import org.springframework.statemachine.state.HistoryPseudoState;
import org.springframework.statemachine.state.JoinPseudoState;
import org.springframework.statemachine.state.JoinPseudoState.JoinStateData;
import org.springframework.statemachine.state.JunctionPseudoState;
import org.springframework.statemachine.state.JunctionPseudoState.JunctionStateData;
import org.springframework.statemachine.state.PseudoState;
@@ -631,34 +632,24 @@ public abstract class AbstractStateMachineFactory<S, E> extends LifecycleObjectS
joins.add(stateMap.get(fs));
}
}
S ss = null;
List<JoinStateData<S, E>> joinTargets = new ArrayList<JoinStateData<S, E>>();
Collection<TransitionData<S, E>> transitions = stateMachineTransitions.getTransitions();
for (TransitionData<S, E> tt : transitions) {
if (tt.getSource() == s) {
ss = tt.getTarget();
break;
StateHolder<S, E> holder = new StateHolder<S, E>(stateMap.get(tt.getTarget()));
if (holder.getState() == null) {
holderMap.put(tt.getTarget(), holder);
}
joinTargets.add(new JoinStateData<S, E>(holder, tt.getGuard()));
}
}
StateHolder<S, E> holder = new StateHolder<S, E>(stateMap.get(ss));
if (holder.getState() == null) {
holderMap.put(ss, holder);
}
JoinPseudoState<S, E> pseudoState = new JoinPseudoState<S, E>(joins, holder);
JoinPseudoState<S, E> pseudoState = new JoinPseudoState<S, E>(joins, joinTargets);
state = buildStateInternal(stateData.getState(), stateData.getDeferred(), stateData.getEntryActions(),
stateData.getExitActions(), pseudoState);
states.add(state);
stateMap.put(stateData.getState(), state);
// find joins sources and associate
for (Entry<S, State<S, E>> e : stateMap.entrySet()) {
State<S, E> value = e.getValue();
if (value.isOrthogonal()) {
Collection<State<S, E>> states2 = value.getStates();
if (states2.containsAll(joins)) {
((RegionState<S, E>)value).setJoin(pseudoState);
}
}
}
}
}
@@ -706,6 +697,23 @@ public abstract class AbstractStateMachineFactory<S, E> extends LifecycleObjectS
}
}
if (stateMachineTransitions.getJoins() != null) {
for (Entry<S, List<S>> entry : stateMachineTransitions.getJoins().entrySet()) {
if (stateMap.get(entry.getKey()) != null) {
List<S> entryList = entry.getValue();
for (S entryState : entryList) {
State<S, E> source = stateMap.get(entryState);
if (source != null && !source.isOrthogonal()) {
State<S, E> target = stateMap.get(entry.getKey());
DefaultExternalTransition<S, E> transition = new DefaultExternalTransition<S, E>(
source, target, null, null, null, null, null);
transitions.add(transition);
}
}
}
}
}
Transition<S, E> initialTransition = new InitialTransition<S, E>(initialState, initialAction);
StateMachine<S, E> machine = buildStateMachineInternal(states, transitions, initialState, initialTransition,
null, defaultExtendedState, historyState, contextEvents, beanFactory, taskExecutor, taskScheduler,

View File

@@ -44,6 +44,7 @@ public abstract class AbstractState<S, E> implements State<S, E> {
private final Collection<Region<S, E>> regions = new ArrayList<Region<S, E>>();
private final StateMachine<S, E> submachine;
private List<Trigger<S, E>> triggers = new ArrayList<Trigger<S, E>>();
private final CompositeStateListener<S, E> stateListener = new CompositeStateListener<S, E>();
/**
* Instantiates a new abstract state.
@@ -162,6 +163,7 @@ public abstract class AbstractState<S, E> implements State<S, E> {
@Override
public void exit(StateContext<S, E> context) {
stateListener.onExit(context);
for (Trigger<S, E> trigger : triggers) {
trigger.disarm();
}
@@ -169,6 +171,7 @@ public abstract class AbstractState<S, E> implements State<S, E> {
@Override
public void entry(StateContext<S, E> context) {
stateListener.onEntry(context);
for (Trigger<S, E> trigger : triggers) {
trigger.arm();
}
@@ -225,6 +228,16 @@ public abstract class AbstractState<S, E> implements State<S, E> {
return submachine != null;
}
@Override
public void addStateListener(StateListener<S, E> listener) {
stateListener.register(listener);
}
@Override
public void removeStateListener(StateListener<S, E> listener) {
stateListener.unregister(listener);
}
/**
* Gets the submachine.
*

View File

@@ -0,0 +1,47 @@
/*
* Copyright 2016 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.statemachine.state;
import java.util.Iterator;
import org.springframework.statemachine.StateContext;
import org.springframework.statemachine.listener.AbstractCompositeListener;
/**
* Composite state listener.
*
* @author Janne Valkealahti
*
* @param <S> the type of state
* @param <E> the type of event
*/
public class CompositeStateListener<S, E> extends AbstractCompositeListener<StateListener<S, E>>
implements StateListener<S, E> {
@Override
public void onEntry(StateContext<S, E> context) {
for (Iterator<StateListener<S, E>> iterator = getListeners().reverse(); iterator.hasNext();) {
iterator.next().onEntry(context);
}
}
@Override
public void onExit(StateContext<S, E> context) {
for (Iterator<StateListener<S, E>> iterator = getListeners().reverse(); iterator.hasNext();) {
iterator.next().onExit(context);
}
}
}

View File

@@ -18,9 +18,12 @@ package org.springframework.statemachine.state;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.statemachine.StateContext;
import org.springframework.statemachine.listener.StateMachineListenerAdapter;
import org.springframework.statemachine.guard.Guard;
import org.springframework.statemachine.state.PseudoStateContext.PseudoAction;
import org.springframework.statemachine.support.StateMachineUtils;
import org.springframework.util.Assert;
/**
@@ -33,36 +36,42 @@ import org.springframework.util.Assert;
*/
public class JoinPseudoState<S, E> extends AbstractPseudoState<S, E> {
private final static Log log = LogFactory.getLog(JoinPseudoState.class);
private final List<State<S, E>> joins;
private volatile JoinTracker tracker;
private final StateHolder<S, E> state;
private final JoinTracker tracker;
private final List<JoinStateData<S, E>> joinTargets;
/**
* Instantiates a new join pseudo state.
*
* @param joins the joins
* @param state the holder for target state
* @param joinTargets the target states
*/
public JoinPseudoState(List<State<S, E>> joins, StateHolder<S, E> state) {
public JoinPseudoState(List<State<S, E>> joins, List<JoinStateData<S, E>> joinTargets) {
super(PseudoStateKind.JOIN);
Assert.notNull(state, "Holder must be set");
this.joins = joins;
this.state = state;
this.joinTargets = joinTargets;
this.tracker = new JoinTracker();
}
@Override
public State<S, E> entry(StateContext<S, E> context) {
tracker = new JoinTracker(this, new ArrayList<State<S,E>>(joins));
context.getStateMachine().addStateListener(tracker);
return state.getState();
if (!tracker.isNotified()) {
return null;
}
State<S, E> s = null;
for (JoinStateData<S, E> c : joinTargets) {
s = c.getState();
if (c.guard != null && evaluateInternal(c.guard, context)) {
break;
}
}
return s;
}
@Override
public void exit(StateContext<S, E> context) {
if (context != null) {
context.getStateMachine().removeStateListener(tracker);
}
tracker = null;
tracker.reset();
}
/**
@@ -74,28 +83,112 @@ public class JoinPseudoState<S, E> extends AbstractPseudoState<S, E> {
return joins;
}
private class JoinTracker extends StateMachineListenerAdapter<S, E> {
private boolean evaluateInternal(Guard<S, E> guard, StateContext<S, E> context) {
try {
return guard.evaluate(context);
} catch (Throwable t) {
log.warn("Deny guard due to throw as GUARD should not error", t);
return false;
}
}
private class JoinTracker {
private final PseudoState<S, E> pseudoState;
private final List<State<S, E>> track;
private volatile boolean notified = false;
public JoinTracker(PseudoState<S, E> pseudoState, List<State<S, E>> track) {
this.pseudoState = pseudoState;
this.track = track;
}
public JoinTracker() {
this.track = new ArrayList<State<S,E>>(joins);
for (State<S, E> tt : joins) {
final State<S, E> t = tt;
t.addStateListener(new StateListener<S, E>() {
@Override
public synchronized void stateChanged(State<S, E> from, State<S, E> to) {
if (!notified && track.size() > 0) {
track.remove(to);
if (track.size() == 0) {
notified = true;
notifyContext(new DefaultPseudoStateContext<S, E>(pseudoState, PseudoAction.JOIN_COMPLETED));
}
@Override
public void onEntry(StateContext<S, E> context) {
if (StateMachineUtils.isPseudoState(context.getTransition().getTarget(), PseudoStateKind.END)) {
if (!notified && track.size() > 0) {
track.remove(t);
if (track.size() == 0) {
notified = true;
notifyContext(new DefaultPseudoStateContext<S, E>(JoinPseudoState.this, PseudoAction.JOIN_COMPLETED));
}
}
}
}
@Override
public void onExit(StateContext<S, E> context) {
if (!notified && track.size() > 0) {
track.remove(t);
if (track.size() == 0) {
notified = true;
notifyContext(new DefaultPseudoStateContext<S, E>(JoinPseudoState.this, PseudoAction.JOIN_COMPLETED));
}
}
}
});
}
}
void reset() {
track.clear();
track.addAll(joins);
notified = false;
}
public boolean isNotified() {
return notified;
}
}
/**
* Data class wrapping join {@link State} and {@link Guard}
* together.
*
* @param <S> the type of state
* @param <E> the type of event
*/
public static class JoinStateData<S, E> {
private final StateHolder<S, E> state;
private final Guard<S, E> guard;
/**
* Instantiates a new join state data.
*
* @param state the state holder
* @param guard the guard
*/
public JoinStateData(StateHolder<S, E> state, Guard<S, E> guard) {
Assert.notNull(state, "Holder must be set");
this.state = state;
this.guard = guard;
}
/**
* Gets the state holder.
*
* @return the state holder
*/
public StateHolder<S, E> getStateHolder() {
return state;
}
/**
* Gets the state.
*
* @return the state
*/
public State<S, E> getState() {
return state.getState();
}
/**
* Gets the guard.
*
* @return the guard
*/
public Guard<S, E> getGuard() {
return guard;
}
}
}

View File

@@ -34,8 +34,6 @@ import org.springframework.statemachine.support.StateMachineUtils;
*/
public class RegionState<S, E> extends AbstractState<S, E> {
private JoinPseudoState<S, E> join;
/**
* Instantiates a new region state.
*
@@ -129,6 +127,7 @@ public class RegionState<S, E> extends AbstractState<S, E> {
@Override
public void exit(StateContext<S, E> context) {
super.exit(context);
for (Region<S, E> region : getRegions()) {
if (region.getState() != null) {
region.getState().exit(context);
@@ -145,9 +144,7 @@ public class RegionState<S, E> extends AbstractState<S, E> {
@Override
public void entry(StateContext<S, E> context) {
if (join != null) {
join.entry(context);
}
super.entry(context);
Collection<? extends Action<S, E>> actions = getEntryActions();
if (actions != null) {
for (Action<S, E> action : actions) {
@@ -201,10 +198,6 @@ public class RegionState<S, E> extends AbstractState<S, E> {
return states;
}
public void setJoin(JoinPseudoState<S, E> join) {
this.join = join;
}
@Override
public String toString() {
return "RegionState [getIds()=" + getIds() + ", getClass()=" + getClass() + ", hashCode()=" + hashCode()

View File

@@ -147,4 +147,17 @@ public interface State<S, E> {
*/
boolean isSubmachineState();
/**
* Adds the state listener.
*
* @param listener the listener
*/
void addStateListener(StateListener<S, E> listener);
/**
* Removes the state listener.
*
* @param listener the listener
*/
void removeStateListener(StateListener<S, E> listener);
}

View File

@@ -0,0 +1,43 @@
/*
* Copyright 2016 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.statemachine.state;
import org.springframework.statemachine.StateContext;
/**
* {@code StateListener} for various state events.
*
* @author Janne Valkealahti
*
* @param <S> the type of state
* @param <E> the type of event
*/
public interface StateListener<S, E> {
/**
* Called when {@link State} want to notify of its entry.
*
* @param context the state context
*/
void onEntry(StateContext<S, E> context);
/**
* Called when {@link State} want to notify of its exit.
*
* @param context the state context
*/
void onExit(StateContext<S, E> context);
}

View File

@@ -136,6 +136,7 @@ public class StateMachineState<S, E> extends AbstractState<S, E> {
@Override
public void exit(StateContext<S, E> context) {
super.exit(context);
// don't stop if it looks like we're coming back
// stop would cause start with entry which would
// enable default transition and state
@@ -156,6 +157,7 @@ public class StateMachineState<S, E> extends AbstractState<S, E> {
@Override
public void entry(final StateContext<S, E> context) {
super.entry(context);
Collection<? extends Action<S, E>> actions = getEntryActions();
if (actions != null && !isLocal(context)) {
for (Action<S, E> action : actions) {

View File

@@ -45,7 +45,6 @@ import org.springframework.statemachine.region.Region;
import org.springframework.statemachine.state.AbstractState;
import org.springframework.statemachine.state.ForkPseudoState;
import org.springframework.statemachine.state.HistoryPseudoState;
import org.springframework.statemachine.state.JoinPseudoState;
import org.springframework.statemachine.state.PseudoState;
import org.springframework.statemachine.state.PseudoStateContext;
import org.springframework.statemachine.state.PseudoStateKind;
@@ -286,11 +285,15 @@ public abstract class AbstractStateMachine<S, E> extends StateMachineObjectSuppo
// TODO: fix above stateContext as it's not used
notifyTransitionStart(buildStateContext(Stage.TRANSITION_START, message, t, getRelayStateMachine()));
notifyTransition(buildStateContext(Stage.TRANSITION, message, t, getRelayStateMachine()));
if (t.getKind() == TransitionKind.INITIAL) {
switchToState(t.getTarget(), message, t, getRelayStateMachine());
notifyStateMachineStarted(buildStateContext(Stage.STATEMACHINE_START, message, t, getRelayStateMachine()));
} else if (t.getKind() != TransitionKind.INTERNAL) {
switchToState(t.getTarget(), message, t, getRelayStateMachine());
if (t.getTarget().getPseudoState() != null && t.getTarget().getPseudoState().getKind() == PseudoStateKind.JOIN) {
exitFromState(t.getSource(), message, t, getRelayStateMachine());
} else {
if (t.getKind() == TransitionKind.INITIAL) {
switchToState(t.getTarget(), message, t, getRelayStateMachine());
notifyStateMachineStarted(buildStateContext(Stage.STATEMACHINE_START, message, t, getRelayStateMachine()));
} else if (t.getKind() != TransitionKind.INTERNAL) {
switchToState(t.getTarget(), message, t, getRelayStateMachine());
}
}
// TODO: looks like events should be called here and anno processing earlier
notifyTransitionEnd(buildStateContext(Stage.TRANSITION_END, message, t, getRelayStateMachine()));
@@ -784,25 +787,29 @@ public abstract class AbstractStateMachine<S, E> extends StateMachineObjectSuppo
@Override
public void onContext(PseudoStateContext<S, E> context) {
PseudoState<S, E> pseudoState = context.getPseudoState();
if (pseudoState.getKind() == PseudoStateKind.JOIN) {
List<State<S, E>> joins = ((JoinPseudoState<S, E>)context.getPseudoState()).getJoins();
for (State<S, E> join : joins) {
exitFromState(join, null, null, getRelayStateMachine());
}
}
State<S, E> toState = findStateWithPseudoState(pseudoState);
State<S, E> toStateOrig = findStateWithPseudoState(pseudoState);
StateContext<S, E> stateContext = buildStateContext(Stage.STATE_EXIT, null, null, getRelayStateMachine());
State<S, E> toState = followLinkedPseudoStates(toStateOrig, stateContext);
// TODO: try to find matching transition based on direct link.
// should make this built-in in pseudostates
Transition<S, E> transition = findTransition(toStateOrig, toState);
switchToState(toState, null, transition, getRelayStateMachine());
pseudoState.exit(stateContext);
toState = followLinkedPseudoStates(toState, stateContext);
// should figure out what transition to use as we pass null for now
// which is then expected in exitCurrentState
switchToState(toState, null, null, getRelayStateMachine());
}
});
}
}
}
private Transition<S, E> findTransition(State<S, E> from, State<S, E> to) {
for (Transition<S, E> transition : transitions) {
if (transition.getSource() == from && transition.getTarget() == to) {
return transition;
}
}
return null;
}
private State<S, E> findStateWithPseudoState(PseudoState<S, E> pseudoState) {
for (State<S, E> s : states) {
if (s.getPseudoState() == pseudoState) {
@@ -984,9 +991,7 @@ public abstract class AbstractStateMachine<S, E> extends StateMachineObjectSuppo
exitFromState(r.getState(), message, transition, stateMachine, sources, targets);
}
}
if (transition == null) {
exitFromState(currentState, message, transition, stateMachine, sources, targets);
}
exitFromState(currentState, message, transition, stateMachine, sources, targets);
} else {
exitFromState(currentState, message, transition, stateMachine, sources, targets);
}

View File

@@ -19,12 +19,14 @@ import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.LinkedList;
import java.util.List;
import java.util.ListIterator;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
@@ -36,9 +38,11 @@ import org.springframework.core.task.TaskExecutor;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.statemachine.StateContext;
import org.springframework.statemachine.StateContext.Stage;
import org.springframework.statemachine.StateMachine;
import org.springframework.statemachine.StateMachineSystemConstants;
import org.springframework.statemachine.StateContext.Stage;
import org.springframework.statemachine.state.JoinPseudoState;
import org.springframework.statemachine.state.PseudoStateKind;
import org.springframework.statemachine.state.State;
import org.springframework.statemachine.transition.Transition;
import org.springframework.statemachine.trigger.DefaultTriggerContext;
@@ -172,6 +176,9 @@ public class DefaultStateMachineExecutor<S, E> extends LifecycleObjectSupport im
interceptors.add(interceptor);
}
private final Set<Transition<S, E>> joinSyncTransitions = new HashSet<>();
private final Set<State<S, E>> joinSyncStates = new HashSet<>();
private boolean handleTriggerTrans(List<Transition<S, E>> trans, Message<E> queuedMessage) {
boolean transit = false;
for (Transition<S, E> t : trans) {
@@ -190,6 +197,28 @@ public class DefaultStateMachineExecutor<S, E> extends LifecycleObjectSupport im
continue;
}
// special handling of join
if (StateMachineUtils.isPseudoState(t.getTarget(), PseudoStateKind.JOIN)) {
if (joinSyncStates.isEmpty()) {
List<State<S, E>> joins = ((JoinPseudoState<S, E>)t.getTarget().getPseudoState()).getJoins();
joinSyncStates.addAll(joins);
}
joinSyncTransitions.add(t);
boolean removed = joinSyncStates.remove(t.getSource());
boolean joincomplete = removed & joinSyncStates.isEmpty();
if (joincomplete) {
for (Transition<S, E> tt : joinSyncTransitions) {
StateContext<S, E> stateContext = buildStateContext(queuedMessage, tt, relayStateMachine);
tt.transit(stateContext);
stateMachineExecutorTransit.transit(tt, stateContext, queuedMessage);
}
joinSyncTransitions.clear();
break;
} else {
continue;
}
}
StateContext<S, E> stateContext = buildStateContext(queuedMessage, t, relayStateMachine);
try {
stateContext = interceptors.preTransition(stateContext);

View File

@@ -95,6 +95,14 @@ public abstract class StateMachineUtils {
}
}
public static <S, E> boolean isPseudoState(State<S, E> state, PseudoStateKind kind) {
if (state != null) {
PseudoState<S, E> pseudoState = state.getPseudoState();
return pseudoState != null && pseudoState.getKind() == kind;
}
return false;
}
public static <S> Collection<String> toStringCollection(Collection<S> collection) {
Collection<String> c = new ArrayList<String>();
for (S item : collection) {

View File

@@ -16,6 +16,7 @@
package org.springframework.statemachine.state;
import static org.hamcrest.Matchers.contains;
import static org.hamcrest.Matchers.containsInAnyOrder;
import static org.hamcrest.Matchers.is;
import static org.hamcrest.Matchers.notNullValue;
import static org.junit.Assert.assertThat;
@@ -24,18 +25,22 @@ import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import org.junit.Test;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.Message;
import org.springframework.statemachine.AbstractStateMachineTests;
import org.springframework.statemachine.ObjectStateMachine;
import org.springframework.statemachine.StateMachine;
import org.springframework.statemachine.StateMachineSystemConstants;
import org.springframework.statemachine.config.EnableStateMachine;
import org.springframework.statemachine.config.EnumStateMachineConfigurerAdapter;
import org.springframework.statemachine.config.builders.StateMachineStateConfigurer;
import org.springframework.statemachine.config.builders.StateMachineTransitionConfigurer;
import org.springframework.statemachine.listener.StateMachineListenerAdapter;
import org.springframework.statemachine.support.StateMachineInterceptorAdapter;
import org.springframework.statemachine.transition.Transition;
public class JoinStateTests extends AbstractStateMachineTests {
@@ -105,16 +110,17 @@ public class JoinStateTests extends AbstractStateMachineTests {
machine.sendEvent(TestEvents.E1);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(3));
assertThat(machine.getState().getIds(), containsInAnyOrder(TestStates.S2, TestStates.S20, TestStates.S30));
listener.reset(1);
machine.sendEvent(TestEvents.E2);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(1));
listener.reset(3);
listener.reset(2);
machine.sendEvent(TestEvents.E3);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(3));
assertThat(listener.stateChangedCount, is(2));
assertThat(machine.getState().getIds(), contains(TestStates.S4));
}
@@ -185,14 +191,128 @@ public class JoinStateTests extends AbstractStateMachineTests {
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(1));
listener.reset(3);
listener.reset(2);
machine.sendEvent(TestEvents.E3);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(2));
assertThat(machine.getState().getIds(), contains(TestStates.S4));
}
@Test
@SuppressWarnings("unchecked")
public void testMultiJoin1() throws Exception {
context.register(BaseConfig.class, Config3.class);
context.refresh();
ObjectStateMachine<TestStates,TestEvents> machine =
context.getBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE, ObjectStateMachine.class);
TestListener listener = new TestListener();
machine.addStateListener(listener);
listener.reset(1);
assertThat(machine, notNullValue());
machine.start();
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(1));
listener.reset(3);
machine.sendEvent(TestEvents.E1);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(3));
listener.reset(1);
machine.sendEvent(TestEvents.E2);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(1));
listener.reset(2);
machine.sendEvent(TestEvents.E3);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(2));
assertThat(machine.getState().getIds(), contains(TestStates.S4));
}
@Test
@SuppressWarnings("unchecked")
public void testMultiJoin2() throws Exception {
context.register(BaseConfig.class, Config3.class);
context.refresh();
ObjectStateMachine<TestStates,TestEvents> machine =
context.getBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE, ObjectStateMachine.class);
TestListener listener = new TestListener();
machine.addStateListener(listener);
listener.reset(1);
assertThat(machine, notNullValue());
machine.start();
machine.getExtendedState().getVariables().put("foo", "bar");
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(1));
listener.reset(3);
machine.sendEvent(TestEvents.E1);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(3));
listener.reset(1);
machine.sendEvent(TestEvents.E2);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(1));
listener.reset(2);
machine.sendEvent(TestEvents.E3);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(2));
assertThat(machine.getState().getIds(), contains(TestStates.SF));
}
@Test
@SuppressWarnings("unchecked")
public void testInterceptorPostStateChangeTransitionNotNull() throws Exception {
context.register(BaseConfig.class, Config1.class);
context.refresh();
ObjectStateMachine<TestStates,TestEvents> machine =
context.getBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE, ObjectStateMachine.class);
TestListener listener = new TestListener();
machine.addStateListener(listener);
final AtomicBoolean nullCheck = new AtomicBoolean(false);
machine.addStateMachineInterceptor(new StateMachineInterceptorAdapter<TestStates,TestEvents>() {
@Override
public void postStateChange(State<TestStates, TestEvents> state, Message<TestEvents> message,
Transition<TestStates, TestEvents> transition, StateMachine<TestStates, TestEvents> stateMachine) {
if (state.getId() == TestStates.S4) {
nullCheck.set(transition == null);
}
super.postStateChange(state, message, transition, stateMachine);
}
});
listener.reset(1);
assertThat(machine, notNullValue());
machine.start();
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(1));
listener.reset(3);
machine.sendEvent(TestEvents.E1);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(3));
listener.reset(1);
machine.sendEvent(TestEvents.E2);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(1));
listener.reset(2);
machine.sendEvent(TestEvents.E3);
assertThat(listener.stateChangedLatch.await(2, TimeUnit.SECONDS), is(true));
assertThat(listener.stateChangedCount, is(2));
assertThat(machine.getState().getIds(), contains(TestStates.S4));
assertThat("Interceptor postStateChange has null transition", nullCheck.get(), is(false));
}
@Configuration
@EnableStateMachine
static class Config1 extends EnumStateMachineConfigurerAdapter<TestStates, TestEvents> {
@@ -312,6 +432,71 @@ public class JoinStateTests extends AbstractStateMachineTests {
}
@Configuration
@EnableStateMachine
static class Config3 extends EnumStateMachineConfigurerAdapter<TestStates, TestEvents> {
@Override
public void configure(StateMachineStateConfigurer<TestStates, TestEvents> states) throws Exception {
states
.withStates()
.initial(TestStates.SI)
.state(TestStates.S2)
.join(TestStates.S3)
.state(TestStates.SF)
.state(TestStates.S4)
.and()
.withStates()
.parent(TestStates.S2)
.initial(TestStates.S20)
.end(TestStates.S21)
.and()
.withStates()
.parent(TestStates.S2)
.initial(TestStates.S30)
.end(TestStates.S31);
}
@Override
public void configure(StateMachineTransitionConfigurer<TestStates, TestEvents> transitions) throws Exception {
transitions
.withExternal()
.source(TestStates.SI)
.target(TestStates.S2)
.event(TestEvents.E1)
.and()
.withExternal()
.source(TestStates.S20)
.target(TestStates.S21)
.event(TestEvents.E2)
.and()
.withExternal()
.source(TestStates.S30)
.target(TestStates.S31)
.event(TestEvents.E3)
.and()
.withJoin()
.source(TestStates.S2)
.target(TestStates.S3)
.and()
.withExternal()
.source(TestStates.S3)
.target(TestStates.SF)
.guardExpression("!extendedState.variables.isEmpty()")
.and()
.withExternal()
.source(TestStates.S3)
.target(TestStates.S4)
.guardExpression("extendedState.variables.isEmpty()")
.and()
.withExternal()
.source(TestStates.S4)
.target(TestStates.SI)
.event(TestEvents.E4);
}
}
private static class TestListener extends StateMachineListenerAdapter<TestStates, TestEvents> {
volatile CountDownLatch stateChangedLatch = new CountDownLatch(1);

View File

@@ -272,7 +272,9 @@ public class TasksHandler {
.initial(initial)
.state(task, runnableAction(node.getData().runnable, node.getData().id.toString()), null);
joinStates.add(task);
if (node.getChildren().isEmpty()) {
joinStates.add(task);
}
stateMachineTransitionConfigurer
.withExternal()

View File

@@ -339,6 +339,39 @@ public class UmlStateMachineModelFactoryTests extends AbstractUmlTests {
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("SF"));
}
@Test
@SuppressWarnings("unchecked")
public void testMultiJoinForkJoin1() {
context.register(Config20.class);
context.refresh();
StateMachine<String, String> stateMachine = context.getBean(StateMachine.class);
stateMachine.start();
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("SI"));
stateMachine.sendEvent("E1");
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S2", "S20", "S30"));
stateMachine.sendEvent("E2");
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S2", "S21", "S30"));
stateMachine.sendEvent("E3");
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S4"));
}
@Test
@SuppressWarnings("unchecked")
public void testMultiJoinForkJoin2() {
context.register(Config20.class);
context.refresh();
StateMachine<String, String> stateMachine = context.getBean(StateMachine.class);
stateMachine.start();
stateMachine.getExtendedState().getVariables().put("foo", "bar");
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("SI"));
stateMachine.sendEvent("E1");
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S2", "S20", "S30"));
stateMachine.sendEvent("E2");
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("S2", "S21", "S30"));
stateMachine.sendEvent("E3");
assertThat(stateMachine.getState().getIds(), containsInAnyOrder("SF"));
}
@Test
@SuppressWarnings("unchecked")
public void testSimpleHistoryShallow() {
@@ -984,6 +1017,24 @@ public class UmlStateMachineModelFactoryTests extends AbstractUmlTests {
}
}
@Configuration
@EnableStateMachine
public static class Config20 extends StateMachineConfigurerAdapter<String, String> {
@Override
public void configure(StateMachineModelConfigurer<String, String> model) throws Exception {
model
.withModel()
.factory(modelFactory());
}
@Bean
public StateMachineModelFactory<String, String> modelFactory() {
Resource model = new ClassPathResource("org/springframework/statemachine/uml/multijoin-forkjoin.uml");
return new UmlStateMachineModelFactory(model);
}
}
public static class LatchAction implements Action<String, String> {
CountDownLatch latch = new CountDownLatch(1);
@Override

View File

@@ -0,0 +1,2 @@
<?xml version="1.0" encoding="UTF-8"?>
<xmi:XMI xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI"/>

View File

@@ -0,0 +1,383 @@
<?xml version="1.0" encoding="UTF-8"?>
<notation:Diagram xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:ecore="http://www.eclipse.org/emf/2002/Ecore" xmlns:notation="http://www.eclipse.org/gmf/runtime/1.0.2/notation" xmlns:style="http://www.eclipse.org/papyrus/infra/viewpoints/policy/style" xmlns:uml="http://www.eclipse.org/uml2/5.0.0/UML" xmi:id="_CsJ_AAPIEeaXyaQL1WyV3A" type="PapyrusUMLStateMachineDiagram" name="StateMachine Diagram" measurementUnit="Pixel">
<children xmi:type="notation:Shape" xmi:id="_CsJ_AQPIEeaXyaQL1WyV3A" type="StateMachine_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="_CsJ_AgPIEeaXyaQL1WyV3A" type="StateMachine_NameLabel">
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_AwPIEeaXyaQL1WyV3A" width="834" height="20"/>
</children>
<children xmi:type="notation:BasicCompartment" xmi:id="_44HGYFhbEea5u-C4k4QikQ" type="StateMachine_RegionCompartment">
<children xmi:type="notation:Shape" xmi:id="_CsJ_BQPIEeaXyaQL1WyV3A" type="Region_Shape">
<eAnnotations xmi:type="ecore:EAnnotation" xmi:id="_CsJ_BgPIEeaXyaQL1WyV3A" source="RegionAnnotationKey">
<details xmi:type="ecore:EStringToStringMapEntry" xmi:id="_CsJ_BwPIEeaXyaQL1WyV3A" key="RegionZoneKey" value=""/>
</eAnnotations>
<children xmi:type="notation:BasicCompartment" xmi:id="_44IUgFhbEea5u-C4k4QikQ" type="Region_SubvertexCompartment">
<children xmi:type="notation:Shape" xmi:id="_IPcocAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialShape">
<children xmi:type="notation:DecorationNode" xmi:id="_IPdPgAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialFloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_IPdPgQPIEeaXyaQL1WyV3A" x="25" y="3"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_IPdPggPIEeaXyaQL1WyV3A" type="Pseudostate_InitialStereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_IPdPgwPIEeaXyaQL1WyV3A" x="25" y="-10"/>
</children>
<element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_IPSQYAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_IPcocQPIEeaXyaQL1WyV3A" x="13" y="85"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_Iy1pYAPIEeaXyaQL1WyV3A" type="State_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="_Iy2QcAPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
<children xmi:type="notation:DecorationNode" xmi:id="_Iy2QcQPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_Iy2QcgPIEeaXyaQL1WyV3A" x="40"/>
</children>
<children xmi:type="notation:BasicCompartment" xmi:id="_44I7kFhbEea5u-C4k4QikQ" type="State_RegionCompartment">
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_Iy2QdAPIEeaXyaQL1WyV3A"/>
</children>
<element xmi:type="uml:State" href="multijoin-forkjoin.uml#_IyviwAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_Iy1pYQPIEeaXyaQL1WyV3A" x="70" y="87"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_LFPJ0APIEeaXyaQL1WyV3A" type="FinalState_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="_LFPJ0gPIEeaXyaQL1WyV3A" type="FinalState_FloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_LFPJ0wPIEeaXyaQL1WyV3A" x="25" y="3"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_LFPJ1APIEeaXyaQL1WyV3A" type="FinalState_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_LFPw4APIEeaXyaQL1WyV3A" x="25" y="-10"/>
</children>
<element xmi:type="uml:FinalState" href="multijoin-forkjoin.uml#_LFC8kAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_LFPJ0QPIEeaXyaQL1WyV3A" x="630" y="77"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_YIMCwAPIEeaXyaQL1WyV3A" type="Pseudostate_ForkShape">
<children xmi:type="notation:DecorationNode" xmi:id="_YIMCwgPIEeaXyaQL1WyV3A" type="Pseudostate_ForkFloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_YIMCwwPIEeaXyaQL1WyV3A" y="-40"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_YIMCxAPIEeaXyaQL1WyV3A" type="Pseudostate_ForkStereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_YIMCxQPIEeaXyaQL1WyV3A" x="25" y="-10"/>
</children>
<element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_YIEuAAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_YIMCwQPIEeaXyaQL1WyV3A" x="150" y="127"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_a9e04APIEeaXyaQL1WyV3A" type="Pseudostate_JoinShape">
<children xmi:type="notation:DecorationNode" xmi:id="_a9e04gPIEeaXyaQL1WyV3A" type="Pseudostate_JoinFloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_a9e04wPIEeaXyaQL1WyV3A" y="-40"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_a9e05APIEeaXyaQL1WyV3A" type="Pseudostate_JoinStereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_a9fb8APIEeaXyaQL1WyV3A" x="25" y="-10"/>
</children>
<element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_a9XgIAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_a9e04QPIEeaXyaQL1WyV3A" x="550" y="127"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_f-AIcAPIEeaXyaQL1WyV3A" type="State_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="_f-AIcgPIEeaXyaQL1WyV3A" type="State_NameLabel">
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_h1M6oAPIEeaXyaQL1WyV3A" width="261" height="20"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_f-AIcwPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_f-AIdAPIEeaXyaQL1WyV3A" x="40"/>
</children>
<children xmi:type="notation:BasicCompartment" xmi:id="_44I7kVhbEea5u-C4k4QikQ" type="State_RegionCompartment">
<children xmi:type="notation:Shape" xmi:id="_iu90MAPIEeaXyaQL1WyV3A" type="Region_Shape">
<eAnnotations xmi:type="ecore:EAnnotation" xmi:id="_iu90NAPIEeaXyaQL1WyV3A" source="RegionAnnotationKey">
<details xmi:type="ecore:EStringToStringMapEntry" xmi:id="_iu90NQPIEeaXyaQL1WyV3A" key="RegionZoneKey" value="T"/>
</eAnnotations>
<children xmi:type="notation:BasicCompartment" xmi:id="_44JioFhbEea5u-C4k4QikQ" type="Region_SubvertexCompartment">
<children xmi:type="notation:Shape" xmi:id="_mL_UsAPIEeaXyaQL1WyV3A" type="State_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="_mL_UsgPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
<children xmi:type="notation:DecorationNode" xmi:id="_mL_UswPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_mL_UtAPIEeaXyaQL1WyV3A" x="40"/>
</children>
<children xmi:type="notation:BasicCompartment" xmi:id="_44KJsFhbEea5u-C4k4QikQ" type="State_RegionCompartment">
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_mL_UtgPIEeaXyaQL1WyV3A"/>
</children>
<element xmi:type="uml:State" href="multijoin-forkjoin.uml#_mL08oAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_mL_UsQPIEeaXyaQL1WyV3A" x="80" y="17"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_mkQDsAPIEeaXyaQL1WyV3A" type="State_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="_mkQDsgPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
<children xmi:type="notation:DecorationNode" xmi:id="_mkQDswPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_mkQDtAPIEeaXyaQL1WyV3A" x="40"/>
</children>
<children xmi:type="notation:BasicCompartment" xmi:id="_44KJsVhbEea5u-C4k4QikQ" type="State_RegionCompartment">
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_mkQDtgPIEeaXyaQL1WyV3A"/>
</children>
<element xmi:type="uml:State" href="multijoin-forkjoin.uml#_mkFEkAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_mkQDsQPIEeaXyaQL1WyV3A" x="180" y="17"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_55n88APIEeaXyaQL1WyV3A" type="Pseudostate_InitialShape">
<children xmi:type="notation:DecorationNode" xmi:id="_55okAAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialFloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_55okAQPIEeaXyaQL1WyV3A" x="25" y="3"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_55okAgPIEeaXyaQL1WyV3A" type="Pseudostate_InitialStereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_55okAwPIEeaXyaQL1WyV3A" x="25" y="-10"/>
</children>
<element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_55YFUAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_55n88QPIEeaXyaQL1WyV3A" x="20" y="17"/>
</children>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_iu90MwPIEeaXyaQL1WyV3A"/>
</children>
<element xmi:type="uml:Region" href="multijoin-forkjoin.uml#_iu8mEAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_iu90MQPIEeaXyaQL1WyV3A" width="261" height="98"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_j0iVIAPIEeaXyaQL1WyV3A" type="Region_Shape">
<eAnnotations xmi:type="ecore:EAnnotation" xmi:id="_j0iVJAPIEeaXyaQL1WyV3A" source="RegionAnnotationKey">
<details xmi:type="ecore:EStringToStringMapEntry" xmi:id="_j0iVJQPIEeaXyaQL1WyV3A" key="RegionZoneKey" value="B"/>
</eAnnotations>
<children xmi:type="notation:BasicCompartment" xmi:id="_44KwwFhbEea5u-C4k4QikQ" type="Region_SubvertexCompartment">
<children xmi:type="notation:Shape" xmi:id="_sraPMAPIEeaXyaQL1WyV3A" type="State_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="_sraPMgPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
<children xmi:type="notation:DecorationNode" xmi:id="_sraPMwPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_sraPNAPIEeaXyaQL1WyV3A" x="40"/>
</children>
<children xmi:type="notation:BasicCompartment" xmi:id="_44LX0FhbEea5u-C4k4QikQ" type="State_RegionCompartment">
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_sraPNgPIEeaXyaQL1WyV3A"/>
</children>
<element xmi:type="uml:State" href="multijoin-forkjoin.uml#_srPQEAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_sraPMQPIEeaXyaQL1WyV3A" x="80" y="39"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_tDMdEAPIEeaXyaQL1WyV3A" type="State_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="_tDNEIAPIEeaXyaQL1WyV3A" type="State_NameLabel"/>
<children xmi:type="notation:DecorationNode" xmi:id="_tDNEIQPIEeaXyaQL1WyV3A" type="State_FloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_tDNEIgPIEeaXyaQL1WyV3A" x="40"/>
</children>
<children xmi:type="notation:BasicCompartment" xmi:id="_44LX0VhbEea5u-C4k4QikQ" type="State_RegionCompartment">
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_tDNEJAPIEeaXyaQL1WyV3A"/>
</children>
<element xmi:type="uml:State" href="multijoin-forkjoin.uml#_tDCFAAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_tDMdEQPIEeaXyaQL1WyV3A" x="180" y="39"/>
</children>
<children xmi:type="notation:Shape" xmi:id="_7hRQMAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialShape">
<children xmi:type="notation:DecorationNode" xmi:id="_7hRQMgPIEeaXyaQL1WyV3A" type="Pseudostate_InitialFloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_7hRQMwPIEeaXyaQL1WyV3A" x="25" y="3"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_7hRQNAPIEeaXyaQL1WyV3A" type="Pseudostate_InitialStereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_7hRQNQPIEeaXyaQL1WyV3A" x="25" y="-10"/>
</children>
<element xmi:type="uml:Pseudostate" href="multijoin-forkjoin.uml#_7hD00APIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_7hRQMQPIEeaXyaQL1WyV3A" x="20" y="59"/>
</children>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_j0iVIwPIEeaXyaQL1WyV3A"/>
</children>
<element xmi:type="uml:Region" href="multijoin-forkjoin.uml#_j0hHAAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_j0iVIQPIEeaXyaQL1WyV3A" y="98" width="261" height="120"/>
</children>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_f-AIdgPIEeaXyaQL1WyV3A" y="20" width="261" height="218"/>
</children>
<element xmi:type="uml:State" href="multijoin-forkjoin.uml#_f92XcAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_f-AIcQPIEeaXyaQL1WyV3A" x="230" y="27" width="261" height="238"/>
</children>
<children xmi:type="notation:Shape" xmi:id="__inPgFhbEea5u-C4k4QikQ" type="State_Shape">
<children xmi:type="notation:DecorationNode" xmi:id="__ipEsFhbEea5u-C4k4QikQ" type="State_NameLabel"/>
<children xmi:type="notation:DecorationNode" xmi:id="__ipEsVhbEea5u-C4k4QikQ" type="State_FloatingNameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="__ipEslhbEea5u-C4k4QikQ" x="40"/>
</children>
<children xmi:type="notation:BasicCompartment" xmi:id="__iprwFhbEea5u-C4k4QikQ" type="State_RegionCompartment">
<layoutConstraint xmi:type="notation:Bounds" xmi:id="__iprwVhbEea5u-C4k4QikQ"/>
</children>
<element xmi:type="uml:State" href="multijoin-forkjoin.uml#__hywIFhbEea5u-C4k4QikQ"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="__inPgVhbEea5u-C4k4QikQ" x="626" y="163"/>
</children>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_CQPIEeaXyaQL1WyV3A"/>
</children>
<element xmi:type="uml:Region" href="multijoin-forkjoin.uml#_CsHiwAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_CgPIEeaXyaQL1WyV3A" width="834" height="290"/>
</children>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_CwPIEeaXyaQL1WyV3A" y="20" width="834" height="290"/>
</children>
<element xmi:type="uml:StateMachine" href="multijoin-forkjoin.uml#_Cr6HYAPIEeaXyaQL1WyV3A"/>
<layoutConstraint xmi:type="notation:Bounds" xmi:id="_CsJ_DAPIEeaXyaQL1WyV3A" x="30" y="30" width="834" height="310"/>
</children>
<styles xmi:type="notation:StringValueStyle" xmi:id="_CsJ_DQPIEeaXyaQL1WyV3A" name="diagram_compatibility_version" stringValue="1.2.0"/>
<styles xmi:type="notation:DiagramStyle" xmi:id="_CsJ_DgPIEeaXyaQL1WyV3A"/>
<styles xmi:type="style:PapyrusViewStyle" xmi:id="_CsJ_DwPIEeaXyaQL1WyV3A">
<owner xmi:type="uml:Model" href="multijoin-forkjoin.uml#_CrssAAPIEeaXyaQL1WyV3A"/>
</styles>
<element xmi:type="uml:StateMachine" href="multijoin-forkjoin.uml#_Cr6HYAPIEeaXyaQL1WyV3A"/>
<edges xmi:type="notation:Connector" xmi:id="_9j8SkAPIEeaXyaQL1WyV3A" type="Transition_Edge" source="_IPcocAPIEeaXyaQL1WyV3A" target="_Iy1pYAPIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_9j8SkwPIEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_9j8SlAPIEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_9j8SlQPIEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_9j8SlgPIEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_9j85oAPIEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_9j85oQPIEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_9j8SkQPIEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_9hO80APIEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_9j8SkgPIEeaXyaQL1WyV3A" points="[8, 2, -39, 10]$[73, 39, 26, 47]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_9ko2IAPIEeaXyaQL1WyV3A" id="(1.0,0.65)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_9ko2IQPIEeaXyaQL1WyV3A" id="(0.0,0.06382978723404255)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_ADeQEAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_Iy1pYAPIEeaXyaQL1WyV3A" target="_YIMCwAPIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_ADeQEwPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_ADeQFAPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_ADeQFQPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_ADeQFgPJEeaXyaQL1WyV3A" x="4" y="26"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_ADeQFwPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_ADeQGAPJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_ADeQEQPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_ADNKUAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_ADeQEgPJEeaXyaQL1WyV3A" points="[9, 5, -48, -31]$[59, 36, 2, 0]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_AEMBwAPJEeaXyaQL1WyV3A" id="(1.0,0.6382978723404256)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_AEMBwQPJEeaXyaQL1WyV3A" id="(0.0,0.375)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_D5uI4APJEeaXyaQL1WyV3A" type="Transition_Edge" source="_YIMCwAPIEeaXyaQL1WyV3A" target="_mL_UsAPIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_D5uI4wPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_D5uI5APJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_D5uI5QPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_D5uI5gPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_D5uI5wPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_D5uI6APJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_D5uI4QPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_D5dDIAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_D5uI4gPJEeaXyaQL1WyV3A" points="[0, 0, -160, 60]$[200, -25, 40, 35]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_D6aFYAPJEeaXyaQL1WyV3A" id="(1.0,0.45)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_D6aFYQPJEeaXyaQL1WyV3A" id="(0.0,0.6595744680851063)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_FgR3AAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_YIMCwAPIEeaXyaQL1WyV3A" target="_sraPMAPIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_FgR3AwPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_FgR3BAPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_FgR3BQPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_FgR3BgPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_FgR3BwPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_FgR3CAPJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_FgR3AQPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_FgAxQAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_FgR3AgPJEeaXyaQL1WyV3A" points="[10, 4, -150, -56]$[197, 103, 37, 43]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_Fg8lYAPJEeaXyaQL1WyV3A" id="(1.0,0.625)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_Fg8lYQPJEeaXyaQL1WyV3A" id="(0.0,0.46808510638297873)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_Hg0LYAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_55n88APIEeaXyaQL1WyV3A" target="_mL_UsAPIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_Hg0ycAPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_Hg0ycQPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_Hg0ycgPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_Hg0ycwPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_Hg0ydAPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_Hg0ydQPJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_Hg0LYQPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_HgkTwAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_Hg0LYgPJEeaXyaQL1WyV3A" points="[8, 1, -52, 0]$[53, -8, -7, -9]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_Hhe5wAPJEeaXyaQL1WyV3A" id="(1.0,0.45)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_Hhe5wQPJEeaXyaQL1WyV3A" id="(0.0,0.2127659574468085)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_IOl3YAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_7hRQMAPIEeaXyaQL1WyV3A" target="_sraPMAPIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_IOmecgPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_IOmecwPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_IOmedAPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_IOmedQPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_IOmedgPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_IOmedwPJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_IOmecAPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_IOTjgAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_IOmecQPJEeaXyaQL1WyV3A" points="[0, 9, -74, 0]$[76, 17, 2, 8]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_IPTCAAPJEeaXyaQL1WyV3A" id="(1.0,0.6)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_IPTCAQPJEeaXyaQL1WyV3A" id="(0.0,0.7659574468085106)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_KIIy8APJEeaXyaQL1WyV3A" type="Transition_Edge" source="_mL_UsAPIEeaXyaQL1WyV3A" target="_mkQDsAPIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_KIIy8wPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_KIIy9APJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_KIIy9QPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_KIIy9gPJEeaXyaQL1WyV3A" x="-2" y="-13"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_KIIy9wPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_KIIy-APJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_KIIy8QPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_KH4UQAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_KIIy8gPJEeaXyaQL1WyV3A" points="[40, 10, -64, -16]$[100, 26, -4, 0]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_KIyTMAPJEeaXyaQL1WyV3A" id="(1.0,0.46808510638297873)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_KIyTMQPJEeaXyaQL1WyV3A" id="(0.0,0.5319148936170213)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_KwWpgAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_sraPMAPIEeaXyaQL1WyV3A" target="_tDMdEAPIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_KwWpgwPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_KwWphAPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_KwWphQPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_KwWphgPJEeaXyaQL1WyV3A" x="1" y="-18"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_KwWphwPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_KwWpiAPJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_KwWpgQPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_KwInEAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_KwWpggPJEeaXyaQL1WyV3A" points="[40, 9, -67, -17]$[100, 27, -7, 1]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_KxAJwAPJEeaXyaQL1WyV3A" id="(1.0,0.6170212765957447)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_KxAJwQPJEeaXyaQL1WyV3A" id="(0.0,0.5531914893617021)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_MofP0APJEeaXyaQL1WyV3A" type="Transition_Edge" source="_mkQDsAPIEeaXyaQL1WyV3A" target="_a9e04APIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_Mof24APJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_Mof24QPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_Mof24gPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_Mof24wPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_Mof25APJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_Mof25QPJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_MofP0QPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_MoM78APJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_MofP0gPJEeaXyaQL1WyV3A" points="[40, 24, -102, -62]$[140, 90, -2, 4]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_MpTvMAPJEeaXyaQL1WyV3A" id="(1.0,0.6170212765957447)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_MpTvMQPJEeaXyaQL1WyV3A" id="(0.0,0.6)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_NR4LEAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_tDMdEAPIEeaXyaQL1WyV3A" target="_a9e04APIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_NR4yIAPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_NR4yIQPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_NR4yIgPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_NR4yIwPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_NR4yJAPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_NR4yJQPJEeaXyaQL1WyV3A" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_NR4LEQPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_NRphkAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_NR4LEgPJEeaXyaQL1WyV3A" points="[40, 15, -103, 43]$[141, -20, -2, 8]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_NSiSYAPJEeaXyaQL1WyV3A" id="(1.0,0.2978723404255319)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_NSi5cAPJEeaXyaQL1WyV3A" id="(0.0,0.825)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_QKNDEAPJEeaXyaQL1WyV3A" type="Transition_Edge" source="_a9e04APIEeaXyaQL1WyV3A" target="_LFPJ0APIEeaXyaQL1WyV3A">
<children xmi:type="notation:DecorationNode" xmi:id="_QKNDEwPJEeaXyaQL1WyV3A" type="Transition_NameLabel">
<styles xmi:type="notation:BooleanValueStyle" xmi:id="_DZ1YsFhcEea5u-C4k4QikQ" name="IS_UPDATED_POSITION" booleanValue="true"/>
<layoutConstraint xmi:type="notation:Location" xmi:id="_QKNqIAPJEeaXyaQL1WyV3A"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_QKNqIQPJEeaXyaQL1WyV3A" type="Transition_GuardLabel">
<styles xmi:type="notation:BooleanValueStyle" xmi:id="_DaccsFhcEea5u-C4k4QikQ" name="IS_UPDATED_POSITION" booleanValue="true"/>
<layoutConstraint xmi:type="notation:Location" xmi:id="_QKNqIgPJEeaXyaQL1WyV3A" x="5" y="9"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_QKNqIwPJEeaXyaQL1WyV3A" type="Transition_StereotypeLabel">
<styles xmi:type="notation:BooleanValueStyle" xmi:id="_DbHyIFhcEea5u-C4k4QikQ" name="IS_UPDATED_POSITION" booleanValue="true"/>
<layoutConstraint xmi:type="notation:Location" xmi:id="_QKNqJAPJEeaXyaQL1WyV3A" y="59"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_QKNDEQPJEeaXyaQL1WyV3A"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_QJ79UAPJEeaXyaQL1WyV3A"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_QKNDEgPJEeaXyaQL1WyV3A" points="[10, 1, -80, -9]$[98, 10, 8, 0]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_QK6NsAPJEeaXyaQL1WyV3A" id="(1.0,0.525)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_QK6NsQPJEeaXyaQL1WyV3A" id="(0.0,0.55)"/>
</edges>
<edges xmi:type="notation:Connector" xmi:id="_IDiHsFhcEea5u-C4k4QikQ" type="Transition_Edge" source="_a9e04APIEeaXyaQL1WyV3A" target="__inPgFhbEea5u-C4k4QikQ">
<children xmi:type="notation:DecorationNode" xmi:id="_IDjV0FhcEea5u-C4k4QikQ" type="Transition_NameLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_IDjV0VhcEea5u-C4k4QikQ"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_IDjV0lhcEea5u-C4k4QikQ" type="Transition_GuardLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_IDjV01hcEea5u-C4k4QikQ" x="4" y="-16"/>
</children>
<children xmi:type="notation:DecorationNode" xmi:id="_IDjV1FhcEea5u-C4k4QikQ" type="Transition_StereotypeLabel">
<layoutConstraint xmi:type="notation:Location" xmi:id="_IDjV1VhcEea5u-C4k4QikQ" y="60"/>
</children>
<styles xmi:type="notation:FontStyle" xmi:id="_IDiHsVhcEea5u-C4k4QikQ"/>
<element xmi:type="uml:Transition" href="multijoin-forkjoin.uml#_IAzj0FhcEea5u-C4k4QikQ"/>
<bendpoints xmi:type="notation:RelativeBendpoints" xmi:id="_IDiHslhcEea5u-C4k4QikQ" points="[591, 206, -643984, -643984]$[657, 227, -643984, -643984]"/>
<sourceAnchor xmi:type="notation:IdentityAnchor" xmi:id="_IFBVcFhcEea5u-C4k4QikQ" id="(1.0,0.725)"/>
<targetAnchor xmi:type="notation:IdentityAnchor" xmi:id="_IFB8gFhcEea5u-C4k4QikQ" id="(0.0,0.3181818181818182)"/>
</edges>
</notation:Diagram>

View File

@@ -0,0 +1,63 @@
<?xml version="1.0" encoding="UTF-8"?>
<uml:Model xmi:version="20131001" xmlns:xmi="http://www.omg.org/spec/XMI/20131001" xmlns:uml="http://www.eclipse.org/uml2/5.0.0/UML" xmi:id="_CrssAAPIEeaXyaQL1WyV3A" name="RootElement">
<packagedElement xmi:type="uml:StateMachine" xmi:id="_Cr6HYAPIEeaXyaQL1WyV3A" name="StateMachine">
<region xmi:type="uml:Region" xmi:id="_CsHiwAPIEeaXyaQL1WyV3A" name="Region1">
<transition xmi:type="uml:Transition" xmi:id="_9hO80APIEeaXyaQL1WyV3A" source="_IPSQYAPIEeaXyaQL1WyV3A" target="_IyviwAPIEeaXyaQL1WyV3A"/>
<transition xmi:type="uml:Transition" xmi:id="_ADNKUAPJEeaXyaQL1WyV3A" source="_IyviwAPIEeaXyaQL1WyV3A" target="_YIEuAAPIEeaXyaQL1WyV3A">
<trigger xmi:type="uml:Trigger" xmi:id="_lTnQUAPKEeaXyaQL1WyV3A" event="_Lej94APKEeaXyaQL1WyV3A"/>
</transition>
<transition xmi:type="uml:Transition" xmi:id="_D5dDIAPJEeaXyaQL1WyV3A" source="_YIEuAAPIEeaXyaQL1WyV3A" target="_mL08oAPIEeaXyaQL1WyV3A"/>
<transition xmi:type="uml:Transition" xmi:id="_FgAxQAPJEeaXyaQL1WyV3A" source="_YIEuAAPIEeaXyaQL1WyV3A" target="_srPQEAPIEeaXyaQL1WyV3A"/>
<transition xmi:type="uml:Transition" xmi:id="_QJ79UAPJEeaXyaQL1WyV3A" guard="_5xWWQFkxEea5u-C4k4QikQ" source="_a9XgIAPIEeaXyaQL1WyV3A" target="_LFC8kAPIEeaXyaQL1WyV3A">
<ownedRule xmi:type="uml:Constraint" xmi:id="_5xWWQFkxEea5u-C4k4QikQ">
<specification xmi:type="uml:OpaqueExpression" xmi:id="_5xWWQVkxEea5u-C4k4QikQ">
<language>spel</language>
<body>!extendedState.variables.isEmpty()</body>
</specification>
</ownedRule>
</transition>
<transition xmi:type="uml:Transition" xmi:id="_IAzj0FhcEea5u-C4k4QikQ" guard="_HRVekFk0Eea5u-C4k4QikQ" source="_a9XgIAPIEeaXyaQL1WyV3A" target="__hywIFhbEea5u-C4k4QikQ">
<ownedRule xmi:type="uml:Constraint" xmi:id="_HRVekFk0Eea5u-C4k4QikQ">
<specification xmi:type="uml:OpaqueExpression" xmi:id="_HRVekVk0Eea5u-C4k4QikQ">
<language>spel</language>
<body>extendedState.variables.isEmpty()</body>
</specification>
</ownedRule>
</transition>
<subvertex xmi:type="uml:Pseudostate" xmi:id="_IPSQYAPIEeaXyaQL1WyV3A"/>
<subvertex xmi:type="uml:State" xmi:id="_IyviwAPIEeaXyaQL1WyV3A" name="SI"/>
<subvertex xmi:type="uml:FinalState" xmi:id="_LFC8kAPIEeaXyaQL1WyV3A" name="SF"/>
<subvertex xmi:type="uml:Pseudostate" xmi:id="_YIEuAAPIEeaXyaQL1WyV3A" name="S1" kind="fork"/>
<subvertex xmi:type="uml:Pseudostate" xmi:id="_a9XgIAPIEeaXyaQL1WyV3A" name="S3" kind="join"/>
<subvertex xmi:type="uml:State" xmi:id="_f92XcAPIEeaXyaQL1WyV3A" name="S2">
<region xmi:type="uml:Region" xmi:id="_iu8mEAPIEeaXyaQL1WyV3A" name="Region1">
<transition xmi:type="uml:Transition" xmi:id="_HgkTwAPJEeaXyaQL1WyV3A" source="_55YFUAPIEeaXyaQL1WyV3A" target="_mL08oAPIEeaXyaQL1WyV3A"/>
<transition xmi:type="uml:Transition" xmi:id="_KH4UQAPJEeaXyaQL1WyV3A" source="_mL08oAPIEeaXyaQL1WyV3A" target="_mkFEkAPIEeaXyaQL1WyV3A">
<trigger xmi:type="uml:Trigger" xmi:id="_pahbUAPKEeaXyaQL1WyV3A" event="_OEQ00APKEeaXyaQL1WyV3A"/>
</transition>
<transition xmi:type="uml:Transition" xmi:id="_MoM78APJEeaXyaQL1WyV3A" source="_mkFEkAPIEeaXyaQL1WyV3A" target="_a9XgIAPIEeaXyaQL1WyV3A"/>
<subvertex xmi:type="uml:State" xmi:id="_mL08oAPIEeaXyaQL1WyV3A" name="S20"/>
<subvertex xmi:type="uml:State" xmi:id="_mkFEkAPIEeaXyaQL1WyV3A" name="S21"/>
<subvertex xmi:type="uml:Pseudostate" xmi:id="_55YFUAPIEeaXyaQL1WyV3A"/>
</region>
<region xmi:type="uml:Region" xmi:id="_j0hHAAPIEeaXyaQL1WyV3A" name="Region2">
<transition xmi:type="uml:Transition" xmi:id="_IOTjgAPJEeaXyaQL1WyV3A" source="_7hD00APIEeaXyaQL1WyV3A" target="_srPQEAPIEeaXyaQL1WyV3A"/>
<transition xmi:type="uml:Transition" xmi:id="_KwInEAPJEeaXyaQL1WyV3A" source="_srPQEAPIEeaXyaQL1WyV3A" target="_tDCFAAPIEeaXyaQL1WyV3A">
<trigger xmi:type="uml:Trigger" xmi:id="_r52kgAPKEeaXyaQL1WyV3A" event="_Qc11wAPKEeaXyaQL1WyV3A"/>
</transition>
<transition xmi:type="uml:Transition" xmi:id="_NRphkAPJEeaXyaQL1WyV3A" source="_tDCFAAPIEeaXyaQL1WyV3A" target="_a9XgIAPIEeaXyaQL1WyV3A"/>
<subvertex xmi:type="uml:State" xmi:id="_srPQEAPIEeaXyaQL1WyV3A" name="S30"/>
<subvertex xmi:type="uml:State" xmi:id="_tDCFAAPIEeaXyaQL1WyV3A" name="S31"/>
<subvertex xmi:type="uml:Pseudostate" xmi:id="_7hD00APIEeaXyaQL1WyV3A"/>
</region>
</subvertex>
<subvertex xmi:type="uml:State" xmi:id="__hywIFhbEea5u-C4k4QikQ" name="S4"/>
</region>
</packagedElement>
<packagedElement xmi:type="uml:Signal" xmi:id="_EqiFUAPKEeaXyaQL1WyV3A" name="E1"/>
<packagedElement xmi:type="uml:Signal" xmi:id="_GO8eYAPKEeaXyaQL1WyV3A" name="E2"/>
<packagedElement xmi:type="uml:Signal" xmi:id="_JdNxMAPKEeaXyaQL1WyV3A" name="E3"/>
<packagedElement xmi:type="uml:SignalEvent" xmi:id="_Lej94APKEeaXyaQL1WyV3A" name="SignalEventE1" signal="_EqiFUAPKEeaXyaQL1WyV3A"/>
<packagedElement xmi:type="uml:SignalEvent" xmi:id="_OEQ00APKEeaXyaQL1WyV3A" name="SignalEventE2" signal="_GO8eYAPKEeaXyaQL1WyV3A"/>
<packagedElement xmi:type="uml:SignalEvent" xmi:id="_Qc11wAPKEeaXyaQL1WyV3A" name="SignalEventE3" signal="_JdNxMAPKEeaXyaQL1WyV3A"/>
</uml:Model>