How to set complete or failure to CompletableFuture?

Question

How can I in the method stopTask() set CompletableFuture complete or failure operation if I had an exception in that method? I have some code:

private static class SenderTask implements Runnable {
    private final Sender sender;

    private ScheduledFuture<?> task;

    @Override
    public void run() {
        try {
            LOGGER.debug("SenderTask {} calling.", sender.getName());
            sender.process();
        } catch (Exception e) {
            LOGGER.error(e);
        }
    }

    public CompletableFuture<SenderTask> stopTask() {
        return CompletableFuture.supplyAsync(() -> {
            task.cancel(false);
            LOGGER.info("Sender {} try stopping.", sender.getName());
            try {
                    task.get(sender.getSenderConfig().getTimeoutConfig().getSendFileTimeout(),` TimeUnit.MILLISECONDS);
                } catch (InterruptedException | ExecutionException | TimeoutException e) {
                    LOGGER.error(e);
                }
                return this;
        });
    }
}

I need to know when my task was stopped.

You could follow this - https://stackoverflow.com/questions/24661989/how-to-know-when-a-thread-stops-or-is-stopped — Hasanuzzaman Rana, Feb 13 '19 at 09:28
Also https://www.algosome.com/articles/knowing-when-threads-stop.html — Hasanuzzaman Rana, Feb 13 '19 at 09:29

score 0 · Answer 1 · answered Feb 13 '19 at 09:56

Could use handle like this:

public CompletableFuture<SenderTask> stopTask() {
   return CompletableFuture.supplyAsync(() -> {
      task.cancel(false);
      LOGGER.info("Sender {} try stopping.", sender.getName()); task.get(sender.getSenderConfig().getTimeoutConfig().getSendFileTimeout(),TimeUnit.MILLISECONDS);
      return this;
  }).handle((res, ex) -> {
      if(ex != null) {
          LOGGER.error(ex);
          ...
      }
      return res;
    });
}

How to set complete or failure to CompletableFuture?

1 Answers1