Exception exception = new RuntimeException("test");
    UncheckedExecutionException e =
        assertThrows(
            UncheckedExecutionException.class,
            () -> timeLimiter.callWithTimeout(callableThrowing(exception), DELAY_MS, MILLISECONDS));
    assertThat(e).hasCauseThat().isEqualTo(exception);
  }

  public void testCallUninterruptiblyWithTimeout_propagatesReturnValue() throws Exception {
    String result =

        assertTrue(exception instanceof RuntimeException);
        assertTrue(exception instanceof Exception);
        assertTrue(exception instanceof Throwable);
    }

    @Test
    public void test_stackTracePresent() {
        // Test that stack trace is captured properly
        ScheduledJobException exception = new ScheduledJobException("Stack trace test");

    assertThat(e).hasCauseThat().isSameInstanceAs(exception);
    assertEquals(Service.State.FAILED, service.state());
  }

  public void testFunctionalStop_failed() {
    Exception exception = new Exception("deliberate");
    AbstractIdleService service =
        new DefaultService() {
          @Override
          protected void shutDown() throws Exception {
            throw exception;
          }
        };

     * Multiple threads call stop() simultaneously - should be safe.
     */
    @Test
    public void test_stop_concurrentAccess() throws Exception {
        final int threadCount = 10;
        final Thread[] threads = new Thread[threadCount];
        final Exception[] exceptions = new Exception[threadCount];

        for (int i = 0; i < threadCount; i++) {
            final int index = i;
            threads[i] = new Thread(() -> {

        // Execute
        final SsoMessageException exception = new SsoMessageException(null, message, cause);

        // Verify
        assertNotNull(exception);
        assertEquals(message, exception.getMessage());
        assertEquals(cause, exception.getCause());
        assertNull(exception.getMessageCode());
    }

    @Test

    private Model read(String pom) throws Exception {
        String resource = "/poms/validation/" + pom;
        try (InputStream is = getClass().getResourceAsStream(resource)) {
            assertNotNull(is, "missing resource: " + resource);
            return new Model(new MavenStaxReader().read(is));
        }
    }

    private SimpleProblemCollector validate(String pom) throws Exception {

              MyException exception3 = new MyException();

              MyException sameInstance = new MyException();
              exception1.initCause(sameInstance);
              exception2.initCause(sameInstance);
              exception3.initCause(exception2);
              getDone(
                  allAsList(immediateFailedFuture(exception1), immediateFailedFuture(exception3)));
            });

              MyException exception3 = new MyException();

              MyException sameInstance = new MyException();
              exception1.initCause(sameInstance);
              exception2.initCause(sameInstance);
              exception3.initCause(exception2);
              getDone(
                  allAsList(immediateFailedFuture(exception1), immediateFailedFuture(exception3)));
            });

        final Exception cause = new RuntimeException("Underlying error");

        // Execute
        final InvalidQueryException exception = new InvalidQueryException(null, message, cause);

        // Verify
        assertNotNull(exception);
        assertEquals(message, exception.getMessage());
        assertEquals(cause, exception.getCause());
        assertNull(exception.getMessageCode());
    }

    @Test

  }

  public void testSetFailure() throws Exception {
    assertTrue(future.setException(new Exception("failure")));
    tester.testFailedFuture("failure");
  }

  public void testSetFailureNull() throws Exception {
    assertThrows(NullPointerException.class, () -> future.setException(null));
    assertFalse(future.isDone());
    assertTrue(future.setException(new Exception("failure")));
    tester.testFailedFuture("failure");
  }