ProcessServiceImpl.java 文件源码

@Transactional
@Async
@Override
public Future<ProcessInfoDTO> stopProcess(final Long piId) {
  final CompletableFuture<ProcessInfoDTO> future = new CompletableFuture<>();

  final ProcessStopMessage.Request request = new ProcessStopMessage.Request(piId);

  PatternsCS.ask(processSupervisorActor, request, Global.TIMEOUT).toCompletableFuture()
      .whenComplete((msg, exc) -> {
        if (exc == null) {
          userSupervisorActor.tell(request, null);
          future.complete(((ProcessStopMessage.Response) msg).getProcess());
        } else {
          future.completeExceptionally(exc);
        }
      });

  return future;
}