Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for interruptTask (0.14 seconds)

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

      abstract T runInterruptibly() throws Exception;
    
      abstract void afterRanInterruptiblySuccess(T result);
    
      abstract void afterRanInterruptiblyFailure(Throwable error);
    
      final void interruptTask() {}
    
      abstract String toPendingString();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/CombinedFuture.java

         */
        if (reason == OUTPUT_FUTURE_DONE) {
          this.task = null;
        }
      }
    
      @Override
      protected void interruptTask() {
        @RetainedLocalRef CombinedFutureInterruptibleTask<?> localTask = task;
        if (localTask != null) {
          localTask.interruptTask();
        }
      }
    
      @WeakOuter
      private abstract class CombinedFutureInterruptibleTask<T extends @Nullable Object>
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.8K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

              }
            };
        Thread runner = new Thread(task);
        runner.start();
        isInterruptibleRegistered.await();
        RuntimeException expected = assertThrows(RuntimeException.class, task::interruptTask);
        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        /*
    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. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

              }
            };
        Thread runner = new Thread(task);
        runner.start();
        isInterruptibleRegistered.await();
        RuntimeException expected = assertThrows(RuntimeException.class, task::interruptTask);
        assertThat(expected)
            .hasMessageThat()
            .isEqualTo("I bet you didn't think Thread.interrupt could throw");
        /*
    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)
  5. android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java

      }
    
      @Override
      protected void afterDone() {
        super.afterDone();
    
        if (wasInterrupted()) {
          InterruptibleTask<?> localTask = task;
          if (localTask != null) {
            localTask.interruptTask();
          }
        }
    
        this.task = null;
      }
    
      @Override
      protected @Nullable String pendingToString() {
        InterruptibleTask<?> localTask = task;
        if (localTask != null) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 5.5K bytes
    - Click Count (0)
Back to Top