Module jdk.incubator.concurrent
Package jdk.incubator.concurrent

Class StructuredTaskScope.ShutdownOnFailure

java.lang.Object
jdk.incubator.concurrent.StructuredTaskScope<Object>
jdk.incubator.concurrent.StructuredTaskScope.ShutdownOnFailure
All Implemented Interfaces:
AutoCloseable
Enclosing class:
StructuredTaskScope<T>
public static final class StructuredTaskScope.ShutdownOnFailure extends StructuredTaskScope<Object>
A StructuredTaskScope that captures the exception of the first task to complete abnormally. Once captured, it invokes the shutdown method to interrupt unfinished threads and wakeup the owner. The policy implemented by this class is intended for cases where the results for all tasks are required ("invoke all"); if any task fails then the results of other unfinished tasks are no longer needed.

Unless otherwise specified, passing a null argument to a method in this class will cause a NullPointerException to be thrown.

Since:
19

  • Constructor Details

    • ShutdownOnFailure

      public ShutdownOnFailure(String name, ThreadFactory factory)
      Constructs a new ShutdownOnSuccess with the given name and thread factory. The task scope is optionally named for the purposes of monitoring and management. The thread factory is used to create threads when tasks are forked. The task scope is owned by the current thread.

      This method captures the current thread's extent-local bindings for inheritance by threads created in the task scope. The Tree Structure section in the class description details how parent-child relations are established implicitly for the purpose of inheritance of extent-local bindings.

      Parameters:
      name - the name of the task scope, can be null
      factory - the thread factory

    • ShutdownOnFailure

      public ShutdownOnFailure()
      Constructs a new unnamed ShutdownOnFailure that creates virtual threads.

      This method is equivalent to invoking the 2-arg constructor with a name of null and a thread factory that creates virtual threads.

  • Method Details

    • handleComplete

      protected void handleComplete(Future<Object> future)
      Shut down the given task scope when invoked for the first time with a task that completed abnormally (exception or cancelled).
      Overrides:
      handleComplete in class StructuredTaskScope<Object>
      Parameters:
      future - the completed task
      See Also:

    • join

      public StructuredTaskScope.ShutdownOnFailure join() throws InterruptedException
      Wait for all threads to finish or the task scope to shut down. This method waits until all threads started in the task scope finish execution (of both task and handleComplete method), or the shutdown method is invoked to shut down the task scope, or the current thread is interrupted.

      This method may only be invoked by the task scope owner.

      Overrides:
      join in class StructuredTaskScope<Object>
      Returns:
      this task scope
      Throws:
      IllegalStateException - if this task scope is closed
      WrongThreadException - if the current thread is not the owner
      InterruptedException - if interrupted while waiting

    • joinUntil

      public StructuredTaskScope.ShutdownOnFailure joinUntil(Instant deadline) throws InterruptedException, TimeoutException
      Wait for all threads to finish or the task scope to shut down, up to the given deadline. This method waits until all threads started in the task scope finish execution (of both task and handleComplete method), the shutdown method is invoked to shut down the task scope, the current thread is interrupted, or the deadline is reached.

      This method may only be invoked by the task scope owner.

      Overrides:
      joinUntil in class StructuredTaskScope<Object>
      Parameters:
      deadline - the deadline
      Returns:
      this task scope
      Throws:
      IllegalStateException - if this task scope is closed
      WrongThreadException - if the current thread is not the owner
      InterruptedException - if interrupted while waiting
      TimeoutException - if the deadline is reached while waiting

    • exception

      public Optional<Throwable> exception()
      Returns the exception for the first task that completed with an exception. If no task completed with an exception but cancelled tasks were notified to the handleComplete method then a CancellationException is returned. If no tasks completed abnormally then an empty Optional is returned.

      This method is intended to be invoked by the task scope owner after it has invoked join (or joinUntil). The behavior of this method is unspecified when invoking thie method before the join is done.

      Returns:
      the exception for a task that completed abnormally or an empty optional if no tasks completed abnormally

    • throwIfFailed

      public void throwIfFailed() throws ExecutionException
      Throws if a task completed abnormally. If any task completed with an exception then ExecutionException is thrown with the exception of the first task to fail as the cause. If no task completed with an exception but cancelled tasks were notified to the handleComplete method then CancellationException is thrown. This method does nothing if no tasks completed abnormally.

      This method is intended to be invoked by the task scope owner after it has invoked join (or joinUntil). The behavior of this method is unspecified when invoking thie method before the join is done.

      Throws:
      ExecutionException - if a task completed with an exception
      CancellationException - if no tasks completed with an exception but tasks were cancelled

    • throwIfFailed

      public <X extends Throwable> void throwIfFailed(Function<Throwable,? extends X> esf) throws X
      Throws the exception produced by the given exception supplying function if a task completed abnormally. If any task completed with an exception then the function is invoked with the exception of the first task to fail. If no task completed with an exception but cancelled tasks were notified to the handleComplete method then the function is called with a CancellationException. The exception returned by the function is thrown. This method does nothing if no tasks completed abnormally.

      This method is intended to be invoked by the task scope owner after it has invoked join (or joinUntil). The behavior of this method is unspecified when invoking thie method before the join is done.

      Type Parameters:
      X - type of the exception to be thrown
      Parameters:
      esf - the exception supplying function
      Throws:
      X - produced by the exception supplying function