Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for interruptTask (0.24 sec)

  1. 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.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. 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.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 10.1K bytes
    - Viewed (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");
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. 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();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 08 20:30:27 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  5. 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.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

          // TODO(lukes): consider adding the StackOverflowError protection from the server version
          delegate.cancel(mayInterruptIfRunning);
        }
    
        return true;
      }
    
      protected void interruptTask() {}
    
      @Override
      public boolean isCancelled() {
        return state.isCancelled();
      }
    
      @Override
      public boolean isDone() {
        return state.isDone();
      }
    
      /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 19:37:41 UTC 2024
    - 12.3K bytes
    - Viewed (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");
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
Back to top