Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 2,074 for _all (0.02 sec)

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

       * {@link MoreExecutors#directExecutor}. Normally, when the first future completes, all the other
       * tasks would be called recursively. Here, we detect that the delegate executor is executing
       * inline, and maintain a queue to dispatch tasks iteratively. There is one instance of this class
       * per call to submit() or submitAsync(), and each instance supports only one call to execute().
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        ListenableFuture<Boolean> future2 =
            serializer.submit(
                new Callable<Boolean>() {
                  @Override
                  public Boolean call() {
                    return blockingCallable.isRunning();
                  }
                },
                directExecutor());
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 20:58:01 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  3. docs/features/connections.md

     * Prefer to alternate IP addresses from different address families, (IPv6 / IPv4), starting with IPv6.
     * Don't start a new attempt until 250 ms after the most recent attempt was started.
     * Keep whichever TCP connection succeeds first and cancel all the others.
     * Race TCP only. Only attempt a TLS handshake on the winning TCP connection.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/math/LongMath.java

         * >60% faster than the Euclidean algorithm in benchmarks.
         */
        int aTwos = Long.numberOfTrailingZeros(a);
        a >>= aTwos; // divide out all 2s
        int bTwos = Long.numberOfTrailingZeros(b);
        b >>= bTwos; // divide out all 2s
        while (a != b) { // both a, b are odd
          // The key to the binary GCD algorithm is as follows:
          // Both a and b are odd. Assume a > b; then gcd(a - b, b) = gcd(a, b).
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Aug 29 16:20:07 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/opensearch/log/bsbhv/BsClickLogBhv.java

        public int[] batchInsert(List<ClickLog> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<ClickLog> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
        public int[] batchUpdate(List<ClickLog> list) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/opensearch/user/bsbhv/BsRoleBhv.java

        public int[] batchInsert(List<Role> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<Role> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
        public int[] batchUpdate(List<Role> list) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsFailureUrlBhv.java

        public int[] batchInsert(List<FailureUrl> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<FailureUrl> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsRequestHeaderBhv.java

        public int[] batchInsert(List<RequestHeader> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<RequestHeader> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsThumbnailQueueBhv.java

        public int[] batchInsert(List<ThumbnailQueue> list, RequestOptionCall<BulkRequestBuilder> call) {
            return batchInsert(list, call, null);
        }
    
        public int[] batchInsert(List<ThumbnailQueue> list, RequestOptionCall<BulkRequestBuilder> call,
                RequestOptionCall<IndexRequestBuilder> entityCall) {
            return doBatchInsert(new BulkList<>(list, call, entityCall), null);
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

      }
    
      /**
       * Cancel all calls currently enqueued or executing. Includes calls executed both
       * [synchronously][Call.execute] and [asynchronously][Call.enqueue].
       */
      @Synchronized
      fun cancelAll() {
        for (call in readyAsyncCalls) {
          call.call.cancel()
        }
        for (call in runningAsyncCalls) {
          call.call.cancel()
        }
        for (call in runningSyncCalls) {
          call.cancel()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 8.7K bytes
    - Viewed (0)
Back to top