fix: 并发性当前状态获取异常、代码调整.
This commit is contained in:
@@ -185,6 +185,14 @@ public abstract class AbstractStateMachine<S> extends AbstractStateManager<S> im
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void publish(Object event) {
|
||||
List<Consumer<StateMachine<S>>> consumers = context.eventRegistries.get(event);
|
||||
if (consumers != null) {
|
||||
consumers.forEach(consumer -> consumer.accept(this));
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public S switchPrevAndGet() {
|
||||
return switchPrevAndGet(true);
|
||||
|
||||
Reference in New Issue
Block a user