Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 353 for queues (0.04 sec)

  1. mockwebserver/README.md

    assertEquals("application/json; charset=utf-8", request.headers["Content-Type"])
    assertEquals("{}", request.body!!.utf8())
    ```
    
    #### Dispatcher
    
    By default MockWebServer uses a queue to specify a series of responses. Use a
    Dispatcher (`import okhttp3.mockwebserver.Dispatcher`) to handle requests using another policy. One natural policy is to
    dispatch on the request path.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Oct 30 21:39:59 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/ServiceManager.java

         *
         * <ol>
         *   <li>Update the {@link #servicesByState()}
         *   <li>Update the {@link #startupTimers}
         *   <li>Based on the new state queue listeners to run
         *   <li>Run the listeners (outside of the lock)
         * </ol>
         */
        void transitionService(Service service, State from, State to) {
          checkNotNull(service);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         *
         * <ol>
         *   <li>Update the {@link #servicesByState()}
         *   <li>Update the {@link #startupTimers}
         *   <li>Based on the new state queue listeners to run
         *   <li>Run the listeners (outside of the lock)
         * </ol>
         */
        void transitionService(Service service, State from, State to) {
          checkNotNull(service);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  4. src/main/java/org/codelibs/fess/entity/FacetInfo.java

                    }
                }
            }
            return BucketOrder.count(false);
        }
    
        /**
         * Adds a query facet to the existing query array.
         * If no queries exist, creates a new array with the provided query.
         *
         * @param s the query string to add as a facet
         */
        public void addQuery(final String s) {
            if (query == null) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/query/WildcardQueryCommand.java

    import org.lastaflute.core.message.UserMessages;
    import org.opensearch.index.query.QueryBuilder;
    import org.opensearch.index.query.QueryBuilders;
    
    /**
     * Query command for handling wildcard queries.
     * Converts Lucene WildcardQuery objects to OpenSearch QueryBuilder objects,
     * supporting wildcard pattern matching with configurable case sensitivity.
     */
    public class WildcardQueryCommand extends QueryCommand {
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/url/-Url.kt

      }
    }
    
    /**
     * Returns a substring of `input` on the range `[pos..limit)` with the following
     * transformations:
     *
     *  * Tabs, newlines, form feeds and carriage returns are skipped.
     *
     *  * In queries, ' ' is encoded to '+' and '+' is encoded to "%2B".
     *
     *  * Characters in `encodeSet` are percent-encoded.
     *
     *  * Control characters and non-ASCII characters are percent-encoded.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  7. docs/contribute/concurrency.md

    #### Per-Connection Locks
    
    Each connection has its own lock. The connections in the pool are all in a `ConcurrentLinkedQueue`. Due to data races, iterators of this queue may return removed connections. Callers must check the connection's `noNewExchanges` property before using connections from the pool.
    
    The connection lock is never held while doing I/O (even closing a socket) to prevent contention.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/service/FailureUrlService.java

            failureUrlBhv.queryDelete(cb -> {
                buildSearchCondition(failureUrlPager, cb);
            });
        }
    
        /**
         * Builds search conditions for failure URL queries based on pager criteria.
         *
         * @param failureUrlPager the pager containing search criteria
         * @param cb the condition builder to configure with search conditions
         */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/RangeMap.java

    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.NoSuchElementException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A mapping from disjoint nonempty ranges to non-null values. Queries look up the value associated
     * with the range (if any) that contains a specified key.
     *
     * <p>In contrast to {@link RangeSet}, no "coalescing" is done of {@linkplain
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/query/DefaultQueryBuilder.java

    import org.opensearch.index.query.QueryShardContext;
    
    /**
     * Default implementation of QueryBuilder that wraps other QueryBuilder instances
     * and provides additional functionality for adding inner queries dynamically.
     * Supports both BoolQueryBuilder and DisMaxQueryBuilder as underlying implementations.
     */
    public class DefaultQueryBuilder implements QueryBuilder {
    
        /** The underlying query builder being wrapped. */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 6.6K bytes
    - Viewed (0)
Back to top