Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 535 for consumer (0.05 sec)

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

        public void run() {
          try {
            future.get();
          } catch (Exception e) {
            // nothing
          }
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        void awaitWaiting() {
          while (!isBlocked()) {
            if (getState() == State.TERMINATED) {
              throw new RuntimeException("Thread exited");
            }
            Thread.yield();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Futures.java

      // 'inputFuture'. That field is non-final and non-volatile. There are 2 places where the
      // 'inputFuture' field is read and where we will have to consider visibility of the write
      // operation in the constructor.
      //
      // 1. In the listener that performs the callback. In this case it is fine since inputFuture is
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/cache/CacheBuilder.java

       *     previously called
       * @since 11.0
       */
      @GwtIncompatible // To be supported
      @CanIgnoreReturnValue // TODO(b/27479612): consider removing this
      public <K1 extends K, V1 extends V> CacheBuilder<K1, V1> weigher(
          Weigher<? super K1, ? super V1> weigher) {
        checkState(this.weigher == null);
        if (strictParsing) {
          checkState(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

        }
    
        /**
         * Extracts keywords from the given query string based on the specified fields.
         *
         * @param q the query string to parse and extract keywords from
         * @param fields the fields to consider when extracting keywords
         * @return a list of unique keywords extracted from the query string
         */
        public static List<String> getKeywords(final String q, final String[] fields) {
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Sun Nov 23 11:21:40 UTC 2025
    - 17.5K bytes
    - Viewed (1)
  5. docs/en/docs/async.md

    * the contents your program gave to the system to be written to disk
    * a remote API operation
    * a database operation to finish
    * a database query to return the results
    * etc.
    
    As the execution time is consumed mostly by waiting for <abbr title="Input and Output">I/O</abbr> operations, they call them "I/O bound" operations.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  6. guava/src/com/google/common/io/BaseEncoding.java

     *
     * @author Louis Wasserman
     * @since 14.0
     */
    @GwtCompatible
    public abstract class BaseEncoding {
      // TODO(lowasser): consider making encodeTo(Appendable, byte[], int, int) public.
    
      BaseEncoding() {}
    
      /**
       * Exception indicating invalid base-encoded input encountered while decoding.
       *
       * @author Louis Wasserman
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Oct 06 14:51:47 UTC 2025
    - 41.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        }
      }
    
      /** Wait for the given thread to reach the {@link State#TIMED_WAITING} thread state. */
      @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
      void awaitTimedWaiting(Thread thread) {
        while (true) {
          switch (thread.getState()) {
            case BLOCKED:
            case NEW:
            case RUNNABLE:
            case WAITING:
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  8. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

     * is not guaranteed to traverse the elements of the MonitorBasedPriorityBlockingQueue in
     * any particular order. If you need ordered traversal, consider using {@code
     * Arrays.sort(pq.toArray())}. Also, method {@code drainTo} can be used to remove some or
     * all elements in priority order and place them in another collection.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * line, then it means that the area (time) is increased, thus storedPermits are more costly than
       * fresh permits, thus the RateLimiter becomes /slower/ after a period of underutilization.
       *
       * Last, but not least: consider a RateLimiter with rate of 1 permit per second, currently
       * completely unused, and an expensive acquire(100) request comes. It would be nonsensical to just
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        public void run() {
          try {
            future.get();
          } catch (Exception e) {
            // nothing
          }
        }
    
        @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait.
        void awaitWaiting() {
          while (!isBlocked()) {
            if (getState() == State.TERMINATED) {
              throw new RuntimeException("Thread exited");
            }
            Thread.yield();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
Back to top