Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for awaitTerminationUninterruptibly (0.68 seconds)

  1. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       *
       * @since 30.0
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static void awaitTerminationUninterruptibly(ExecutorService executor) {
        // TODO(cpovirk): We could optimize this to avoid calling nanoTime() at all.
        verify(awaitTerminationUninterruptibly(executor, Long.MAX_VALUE, NANOSECONDS));
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        assertFalse(awaitTerminationUninterruptibly(executor, 1000, MILLISECONDS));
        assertFalse(executor.isTerminated());
        assertInterrupted();
      }
    
      public void testTryAwaitTerminationInfiniteTimeout() {
        ExecutorService executor = newFixedThreadPool(1);
        requestInterruptIn(500);
        executor.execute(new SleepTask(1000));
        executor.shutdown();
        awaitTerminationUninterruptibly(executor);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        assertFalse(awaitTerminationUninterruptibly(executor, 1000, MILLISECONDS));
        assertFalse(executor.isTerminated());
        assertInterrupted();
      }
    
      public void testTryAwaitTerminationInfiniteTimeout() {
        ExecutorService executor = newFixedThreadPool(1);
        requestInterruptIn(500);
        executor.execute(new SleepTask(1000));
        executor.shutdown();
        awaitTerminationUninterruptibly(executor);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

          throw new AssertionError("Unexpected exception", e);
        } finally {
          executor.shutdownNow();
          // TODO(cpovirk): assertTrue(awaitTerminationUninterruptibly(executor, 10, SECONDS));
        }
      }
    
      /**
       * For each possible pair of futures from {@link TestFutureBatch}, for each possible completion
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

          throw new AssertionError("Unexpected exception", e);
        } finally {
          executor.shutdownNow();
          // TODO(cpovirk): assertTrue(awaitTerminationUninterruptibly(executor, 10, SECONDS));
        }
      }
    
      /**
       * For each possible pair of futures from {@link TestFutureBatch}, for each possible completion
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
Back to Top