Интерфейс StructuredTaskScope.Joiner<T,R>

default boolean onFork(StructuredTaskScope.SubtaskPREVIEW<? extends T> subtask)

Примечание к API:

Этот метод вызывается методами fork. Его не следует вызывать напрямую.

Требования к реализации:

Реализация по умолчанию выбрасывает NullPointerException, если подзадача имеет значение null. Если подзадача не находится в состоянии UNAVAILABLE^PREVIEW, выбрасывается IllegalArgumentException; в противном случае возвращается false.

Параметры:

subtask — подзадача

Возвращает:

true для отмены области видимости; в противном случае false

default boolean onComplete(StructuredTaskScope.SubtaskPREVIEW<? extends T> subtask)

Примечание к API:

Этот метод вызывается подзадачами при их завершении. Его не следует вызывать напрямую.

Требования к реализации:

Реализация по умолчанию выбрасывает NullPointerException, если подзадача имеет значение null. Если подзадача не находится в состоянии SUCCESS^PREVIEW или FAILED^PREVIEW, выбрасывается IllegalArgumentException; в противном случае возвращается false.

Параметры:

subtask — подзадача

Возвращает:

true для отмены области видимости; в противном случае false

R result() throws Throwable

Примечание к API:

Этот метод вызывается методом join. Его не следует вызывать напрямую.

Возвращает:

результат

Выбрасывает:

Throwable — исключение

static <T> StructuredTaskScope.JoinerPREVIEW<T, Stream<StructuredTaskScope.SubtaskPREVIEW<T>>> allSuccessfulOrThrow()

Примечание к API:

Объекты joiner, возвращаемые этим методом, подходят для случаев, когда все подзадачи возвращают результат одного типа. Объекты joiner, возвращаемые методом awaitAllSuccessfulOrThrow(), подходят для случаев, когда подзадачи возвращают результаты разных типов.

Параметры типа:

T — тип результата подзадач

Возвращает:

новый объект Joiner, который возвращает поток всех подзадач после их успешного завершения

static <T> StructuredTaskScope.JoinerPREVIEW<T,T> anySuccessfulResultOrThrow()

Параметры типа:

T — тип результата подзадач

Возвращает:

новый объект Joiner, который возвращает результат любой успешно завершившейся подзадачи

static <T> StructuredTaskScope.JoinerPREVIEW<T,Void> awaitAllSuccessfulOrThrow()

Примечание к API:

Объекты joiner, возвращаемые этим методом, подходят для случаев, когда подзадачи возвращают результаты разных типов. Объекты joiner, возвращаемые методом allSuccessfulOrThrow(), подходят для случаев, когда подзадачи возвращают результат одного типа.

Параметры типа:

T — тип результата подзадач

Возвращает:

новый объект Joiner, который ожидает успешного завершения подзадач

static <T> StructuredTaskScope.JoinerPREVIEW<T,Void> awaitAll()

Примечание к API:

Этот Joiner полезен в случаях, когда подзадачи используют побочные эффекты, а не возвращают результаты или завершаются с исключениями. Метод fork(Runnable)^PREVIEW можно использовать для создания подзадач, не возвращающих результат.

Этот Joiner также можно использовать в сценариях fan-in, когда подзадачи создаются для обработки входящих соединений и их количество не ограничено. В этом примере поток, выполняющий метод acceptLoop, остановится только при прерывании или асинхронном закрытии сокета прослушивания.

  void acceptLoop(ServerSocket listener) throws IOException, InterruptedException {
      try (var scope = StructuredTaskScope.open(Joiner.<Socket>awaitAll())) {
          while (true) {
              Socket socket = listener.accept();
              scope.fork(() -> handle(socket));
          }
      }
  }

Параметры типа:

T — тип результата подзадач

Возвращает:

новый объект Joiner, который ожидает завершения всех подзадач

static <T> StructuredTaskScope.JoinerPREVIEW<T, Stream<StructuredTaskScope.SubtaskPREVIEW<T>>> allUntil(Predicate<StructuredTaskScope.SubtaskPREVIEW<? extends T>> isDone)

   class CancelAfterTwoFailures<T> implements Predicate<Subtask<? extends T>> {
        private final AtomicInteger failedCount = new AtomicInteger();
        @Override
        public boolean test(Subtask<? extends T> subtask) {
            return subtask.state() == Subtask.State.FAILED
                    && failedCount.incrementAndGet() >= 2;
        }
    }

    var joiner = Joiner.all(new CancelAfterTwoFailures<String>());

   <T> List<Subtask<T>> invokeAll(Collection<Callable<T>> tasks) throws InterruptedException {
       try (var scope = StructuredTaskScope.open(Joiner.<T>allUntil(_ -> false))) {
           tasks.forEach(scope::fork);
           return scope.join().toList();
       }
   }

Параметры типа:

T — тип результата подзадач

Параметры:

isDone — предикат для проверки завершённых подзадач

Возвращает:

новый объект Joiner, который возвращает поток всех подзадач после их завершения или если предикат возвращает true для отмены области видимости