Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for runInterruptibly (0.08 sec)

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

         * 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();
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  2. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/InterruptibleTask.java

      @Override
      public void run() {
        T result = null;
        Throwable error = null;
        if (isDone()) {
          return;
        }
        try {
          result = runInterruptibly();
        } catch (Throwable t) {
          error = t;
        }
        if (error == null) {
          // The cast is safe because of the `run` and `error` checks.
          afterRanInterruptiblySuccess(uncheckedCastNullableTToT(result));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java

        }
    
        @Override
        final boolean isDone() {
          return TrustedListenableFutureTask.this.isDone();
        }
    
        @Override
        @ParametricNullness
        V runInterruptibly() throws Exception {
          return callable.call();
        }
    
        @Override
        void afterRanInterruptiblySuccess(@ParametricNullness V result) {
          TrustedListenableFutureTask.this.set(result);
        }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      // Implementation Note: As of 3-7-11, the logic for each blocking/timeout
      // methods is identical, save for method being invoked.
    
      /** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static void awaitUninterruptibly(CountDownLatch latch) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
Back to top