Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for interruptTask (0.49 seconds)

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

      /**
       * Any interruption that happens as a result of calling interruptTask will arrive before this
       * method is called. Complete Futures here.
       */
      abstract void afterRanInterruptiblySuccess(@ParametricNullness T result);
    
      /**
       * Any interruption that happens as a result of calling interruptTask will arrive before this
       * method is called. Complete Futures here.
       */
    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/src/com/google/common/util/concurrent/AbstractFuture.java

          future.releaseWaiters();
          /*
           * We call interruptTask() immediately before afterDone() so that migrating between the two
           * can be a no-op.
           */
          if (callInterruptTask) {
            future.interruptTask();
            /*
             * Interruption doesn't propagate through a DelegatingToFuture chain (see getFutureValue),
             * so don't invoke interruptTask on any subsequent futures.
             */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        public boolean cancel(boolean mayInterruptIfRunning) {
          if (!sync.cancel(mayInterruptIfRunning)) {
            return false;
          }
          executionList.execute();
          if (mayInterruptIfRunning) {
            interruptTask();
          }
          return true;
        }
    
        /**
         * Subclasses can override this method to implement interruption of the future's computation.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        public boolean cancel(boolean mayInterruptIfRunning) {
          if (!sync.cancel(mayInterruptIfRunning)) {
            return false;
          }
          executionList.execute();
          if (mayInterruptIfRunning) {
            interruptTask();
          }
          return true;
        }
    
        /**
         * Subclasses can override this method to implement interruption of the future's computation.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        }
      }
    
      private static final class InterruptibleFuture extends AbstractFuture<String> {
        boolean interruptTaskWasCalled;
    
        @Override
        protected void interruptTask() {
          assertFalse(interruptTaskWasCalled);
          interruptTaskWasCalled = true;
        }
      }
    
      private static boolean isWindows() {
        return OS_NAME.value().startsWith("Windows");
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        }
      }
    
      private static final class InterruptibleFuture extends AbstractFuture<String> {
        boolean interruptTaskWasCalled;
    
        @Override
        protected void interruptTask() {
          assertFalse(interruptTaskWasCalled);
          interruptTaskWasCalled = true;
        }
      }
    
      private static boolean isWindows() {
        return OS_NAME.value().startsWith("Windows");
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
Back to Top