Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 532 for take (0.19 sec)

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

      @Override
      public int remainingCapacity() {
        return delegate().remainingCapacity();
      }
    
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      public E take() throws InterruptedException {
        return delegate().take();
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java

      @Override
      public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offer(e, timeout, unit);
      }
    
      @Override
      public E take() throws InterruptedException {
        return delegate().take();
      }
    
      @Override
      @CheckForNull
      public E poll(long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().poll(timeout, unit);
      }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/escape/EscapersTest.java

        assertEquals("XheXXuickXXrownXXoxX", builder.build().escape("The Quick Brown Fox!"));
        // Explicit replacements take priority over unsafe characters.
        builder.addEscape(' ', "_");
        builder.addEscape('!', "_");
        assertEquals("Xhe_Xuick_Xrown_Xox_", builder.build().escape("The Quick Brown Fox!"));
        // Explicit replacements take priority over safe characters.
        builder.setSafeRange(' ', '~');
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Oct 10 19:45:10 GMT 2022
    - 5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          // we allow one second worth of work to go in a burst (i.e. take less than a second)
          assertTrue(burst <= 1000);
          long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
          // but work beyond that must take at least one second
          assertTrue(afterBurst >= 1000);
        }
      }
    
      /**
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          }
        }
      }
    
      /** Invokes {@code queue.}{@link BlockingQueue#take() take()} uninterruptibly. */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static <E> E takeUninterruptibly(BlockingQueue<E> queue) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
              return queue.take();
            } catch (InterruptedException e) {
              interrupted = true;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 14.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

      @Override
      public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offer(e, timeout, unit);
      }
    
      @Override
      public E take() throws InterruptedException {
        return delegate().take();
      }
    
      @Override
      @CheckForNull
      public E poll(long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().poll(timeout, unit);
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Mar 13 14:30:51 GMT 2023
    - 4.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/cache/CacheBuilderSpec.java

          this.strength = strength;
        }
    
        @Override
        public void parse(CacheBuilderSpec spec, String key, @CheckForNull String value) {
          checkArgument(value == null, "key %s does not take values", key);
          checkArgument(spec.keyStrength == null, "%s was already set to %s", key, spec.keyStrength);
          spec.keyStrength = strength;
        }
      }
    
      /** Parse weakValues and softValues */
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Aug 22 14:27:44 GMT 2022
    - 18.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/math/DoubleMath.java

       *     values.
       */
      @Deprecated
      // com.google.common.math.DoubleUtils
      @GwtIncompatible
      public static double mean(double... values) {
        checkArgument(values.length > 0, "Cannot take mean of 0 values");
        long count = 1;
        double mean = checkFinite(values[0]);
        for (int index = 1; index < values.length; ++index) {
          checkFinite(values[index]);
          count++;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 07 17:50:39 GMT 2024
    - 18.9K bytes
    - Viewed (0)
  9. maven-core/src/main/java/org/apache/maven/lifecycle/DefaultLifecycleExecutor.java

        // it's all encapsulated here so it appears normalized to the POM builder.
    
        // We are going to take the project packaging and find all plugin in the default lifecycle and create
        // fully populated Plugin objects, including executions with goals and default configuration taken
        // from the plugin.xml inside a plugin.
        //
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Wed Feb 28 23:31:09 GMT 2024
    - 7K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          // we allow one second worth of work to go in a burst (i.e. take less than a second)
          assertTrue(burst <= 1000);
          long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
          // but work beyond that must take at least one second
          assertTrue(afterBurst >= 1000);
        }
      }
    
      /**
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.6K bytes
    - Viewed (0)
Back to top