Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for runInterruptibly (0.09 seconds)

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

         * interrupt before, during, or after runInterruptibly() (unless it produced an
         * InterruptedException caught above) can linger and affect listeners.
         */
      }
    
      /**
       * Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not
       * be called.
       */
      abstract boolean isDone();
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        SettableFuture<String> taskResult = SettableFuture.create();
        InterruptibleTask<String> task =
            new InterruptibleTask<String>() {
              @Override
              String runInterruptibly() throws Exception {
                BrokenChannel bc = new BrokenChannel();
                bc.doBegin();
                isInterruptibleRegistered.countDown();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        SettableFuture<String> taskResult = SettableFuture.create();
        InterruptibleTask<String> task =
            new InterruptibleTask<String>() {
              @Override
              String runInterruptibly() throws Exception {
                BrokenChannel bc = new BrokenChannel();
                bc.doBegin();
                isInterruptibleRegistered.countDown();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

     *
     * @author Anthony Zana
     * @since 10.0
     */
    @GwtCompatible
    public final class Uninterruptibles {
      /** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static void awaitUninterruptibly(CountDownLatch latch) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
    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)
  5. android/guava/src/com/google/common/util/concurrent/Futures.java

        return FuturesGetChecked.getChecked(future, exceptionClass, timeout, unit);
      }
    
      /**
       * Returns the result of calling {@link Future#get()} uninterruptibly on a task known not to throw
       * a checked exception. This makes {@code Future} more suitable for lightweight, fast-running
       * tasks that, barring bugs in the code, will not fail. This gives it exception-handling behavior
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/cache/LocalCache.java

                  loadingValueReference.setException(t);
                }
              },
              directExecutor());
          return loadingFuture;
        }
    
        /** Waits uninterruptibly for {@code newValue} to be loaded, and then records loading stats. */
        @CanIgnoreReturnValue
        V getAndRecordStats(
            K key,
            int hash,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 143.5K bytes
    - Click Count (0)
  7. guava/src/com/google/common/cache/LocalCache.java

                  loadingValueReference.setException(t);
                }
              },
              directExecutor());
          return loadingFuture;
        }
    
        /** Waits uninterruptibly for {@code newValue} to be loaded, and then records loading stats. */
        @CanIgnoreReturnValue
        V getAndRecordStats(
            K key,
            int hash,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 148.9K bytes
    - Click Count (0)
Back to Top