Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for awaitTerminationUninterruptibly (0.39 sec)

  1. 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));
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 18.7K bytes
    - Viewed (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);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jun 10 16:06:39 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  3. 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));
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 14.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.InterruptionUtil.repeatedlyInterruptTestThread;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitTerminationUninterruptibly;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 30.9K bytes
    - Viewed (0)
  5. 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
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
  6. 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
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 144.1K bytes
    - Viewed (0)
Back to top