Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for clearSeenExceptions (0.76 sec)

  1. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AggregateFutureState.java

        }
        return seenExceptions;
      }
    
      abstract void addInitialException(Set<Throwable> seen);
    
      final int decrementRemainingAndGet() {
        return --remaining;
      }
    
      final void clearSeenExceptions() {
        seenExceptions = null;
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Dec 08 20:30:27 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/AggregateFuture.java

          boolean wasInterrupted = wasInterrupted();
          for (Future<?> future : localFutures) {
            future.cancel(wasInterrupted);
          }
        }
        /*
         * We don't call clearSeenExceptions() until processCompleted(). Prior to that, it may be needed
         * again if some outstanding input fails.
         */
      }
    
      @Override
      @CheckForNull
      protected final String pendingToString() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

      abstract void addInitialException(Set<Throwable> seen);
    
      final int decrementRemainingAndGet() {
        return ATOMIC_HELPER.decrementAndGetRemainingCount(this);
      }
    
      final void clearSeenExceptions() {
        seenExceptions = null;
      }
    
      private abstract static class AtomicHelper {
        /** Atomic compare-and-set of the {@link AggregateFutureState#seenExceptions} field. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

          boolean wasInterrupted = wasInterrupted();
          for (Future<?> future : localFutures) {
            future.cancel(wasInterrupted);
          }
        }
        /*
         * We don't call clearSeenExceptions() until processCompleted(). Prior to that, it may be needed
         * again if some outstanding input fails.
         */
      }
    
      @Override
      @CheckForNull
      protected final String pendingToString() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AggregateFutureState.java

      abstract void addInitialException(Set<Throwable> seen);
    
      final int decrementRemainingAndGet() {
        return ATOMIC_HELPER.decrementAndGetRemainingCount(this);
      }
    
      final void clearSeenExceptions() {
        seenExceptions = null;
      }
    
      private abstract static class AtomicHelper {
        /** Atomic compare-and-set of the {@link AggregateFutureState#seenExceptions} field. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 28 20:40:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top