Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for cancel (0.15 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        assertFailed(future, cause);
      }
    
      public void testCanceled() throws Exception {
        assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, false);
      }
    
      public void testInterrupted() throws Exception {
        assertThat(future.cancel(true /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, true);
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  2. .github/workflows/ci.yml

                java: 21
                root-pom: pom.xml
        runs-on: ${{ matrix.os }}
        env:
          ROOT_POM: ${{ matrix.root-pom }}
        steps:
          # Cancel any previous runs for the same branch that are still running.
          - name: 'Cancel previous runs'
            uses: styfle/cancel-workflow-action@85880fa0301c86cca9da44039ee3bb12d3bedbfa # 0.12.1
            with:
              access_token: ${{ github.token }}
          - name: 'Check out repository'
    Others
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 24 19:33:50 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        assertFailed(future, cause);
      }
    
      public void testCanceled() throws Exception {
        assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, false);
      }
    
      public void testInterrupted() throws Exception {
        assertThat(future.cancel(true /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, true);
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

      }
    
      public void testCancelled() throws Exception {
        TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
        assertFalse(task.isDone());
        task.cancel(false);
        assertTrue(task.isDone());
        assertTrue(task.isCancelled());
        assertFalse(task.wasInterrupted());
        try {
          getDone(task);
          fail();
        } catch (CancellationException expected) {
        }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

       * write.
       *
       * 2. visibility of the writes to an afterDone() call triggered by cancel():
       *
       * Since these fields are non-final that means that TimeoutFuture is not being 'safely published',
       * thus a motivated caller may be able to expose the reference to another thread that would then
       * call cancel() and be unable to cancel the delegate.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  6. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

        public final void addListener(Runnable listener, Executor executor) {
          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
        @Override
        public final boolean cancel(boolean mayInterruptIfRunning) {
          return super.cancel(mayInterruptIfRunning);
        }
      }
    
      private static final Logger log = Logger.getLogger(AbstractFuture.class.getName());
    
      private State state;
      private V value;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jan 22 19:37:41 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java

                      + listener
                      + " with executor "
                      + executor,
                  e);
        }
      }
    
      @Override
      public boolean cancel(boolean mayInterruptIfRunning) {
        return false;
      }
    
      // TODO(lukes): Consider throwing InterruptedException when appropriate.
      @Override
      @ParametricNullness
      public V get() {
        return value;
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 3.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      }
    
      private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception {
        // Simple (combined.cancel -> input.cancel -> setOneValue):
        successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true);
    
        /*
         * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue),
         * to show that this isn't just about problems with the input future we just
         * cancelled:
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

      }
    
      private static void doTestSuccessfulAsList_resultCancelledRacingInputDone() throws Exception {
        // Simple (combined.cancel -> input.cancel -> setOneValue):
        successfulAsList(ImmutableList.of(SettableFuture.create())).cancel(true);
    
        /*
         * Complex (combined.cancel -> input.cancel -> other.set -> setOneValue),
         * to show that this isn't just about problems with the input future we just
         * cancelled:
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        orig.cancel(true);
        assertTrue(orig.isCancelled());
        assertTrue(prev.isCancelled());
        assertTrue(prev.wasInterrupted());
      }
    
      public void testSetFutureSelf_cancel() {
        SettableFuture<String> orig = SettableFuture.create();
        orig.setFuture(orig);
        orig.cancel(true);
        assertTrue(orig.isCancelled());
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
Back to top