Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 84 for cartel (1.17 sec)

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

      protected ForwardingFuture() {}
    
      @Override
      protected abstract Future<? extends V> delegate();
    
      @Override
      @CanIgnoreReturnValue
      public boolean cancel(boolean mayInterruptIfRunning) {
        return delegate().cancel(mayInterruptIfRunning);
      }
    
      @Override
      public boolean isCancelled() {
        return delegate().isCancelled();
      }
    
      @Override
      public boolean isDone() {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Mar 04 12:28:17 GMT 2022
    - 3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/base/CaseFormat.java

      LOWER_CAMEL(CharMatcher.inRange('A', 'Z'), "") {
        @Override
        String normalizeWord(String word) {
          return firstCharOnlyToUpper(word);
        }
    
        @Override
        String normalizeFirstWord(String word) {
          return Ascii.toLowerCase(word);
        }
      },
    
      /** Java and C++ class naming convention, e.g., "UpperCamel". */
      UPPER_CAMEL(CharMatcher.inRange('A', 'Z'), "") {
        @Override
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Mon Dec 19 20:20:14 GMT 2022
    - 6.3K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java

        assertThatFutureBecomesCancelled(closingFuture.finishToFuture());
      }
    
      @Override
      void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) {
        assertThat(closingFuture.finishToFuture().cancel(false)).isTrue();
        waitUntilClosed(closingFuture);
        futureCancelled.countDown();
      }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 3.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetCheckedUntimed_cancelled() throws TwoArgConstructorException {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        assertThrows(
            CancellationException.class, () -> getChecked(future, TwoArgConstructorException.class));
      }
    
      public void testGetCheckedUntimed_ExecutionExceptionChecked() {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java

        return new TrustedListenableFutureTask<>(Executors.callable(runnable, result));
      }
    
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       *
       * <p>{@code volatile} is required for j2objc transpiling:
       * https://developers.google.com/j2objc/guides/j2objc-memory-model#atomicity
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Oct 01 17:18:04 GMT 2021
    - 5.6K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       * State#RUNNING}. Services that need to cancel startup work can override {@link #doCancelStart}.
       */
      @ForOverride
      protected abstract void doStop();
    
      /**
       * This method is called by {@link #stopAsync} when the service is still starting (i.e. {@link
       * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        step2Waiter.awaitStarted();
    
        // Everything should still be open.
        assertStillOpen(closeable1, closeable2, closeable3, closeable4);
    
        // Cancel step 3, resume step 2, and pause in step 4.
        assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue();
        step2Waiter.awaitReturned();
        step4Waiter.awaitStarted();
    
        // Step 1 is not cancelled because it was done.
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 74.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        UNSATISFIED_BEFORE_AND_WHILE_WAITING,
        UNSATISFIED_AND_INTERRUPTED_BEFORE_WAITING;
    
        @Override
        public String toString() {
          return CaseFormat.UPPER_UNDERSCORE.to(CaseFormat.UPPER_CAMEL, name());
        }
      }
    
      /** Timeout values to combine with each {@link Scenario}. */
      private enum Timeout {
        MIN(Long.MIN_VALUE, "-oo"),
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 26.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

          throw new UnsupportedOperationException("test should not care about this");
        }
    
        @Override
        public long getDelay(TimeUnit unit) {
          throw new UnsupportedOperationException("test should not care about this");
        }
    
        @Override
        public int compareTo(Delayed other) {
          throw new UnsupportedOperationException("test should not care about this");
        }
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  10. 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 Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
Back to top