Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 212 for blocking (0.07 sec)

  1. android/guava/src/com/google/common/hash/BloomFilterStrategies.java

         *
         * <p>Note that because of concurrent set calls and uses of atomics, this bitCount is a (very)
         * close *estimate* of the actual number of bits set. It's not possible to do better than an
         * estimate without locking. Note that the number, if not exactly accurate, is *always*
         * underestimating, never overestimating.
         */
        long bitCount() {
          return bitCount.sum();
        }
    
        LockFreeBitArray copy() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/Tables.java

          Cell<C, R, V> transposeCell(Cell<R, C, V> cell) {
        return immutableCell(cell.getColumnKey(), cell.getRowKey(), cell.getValue());
      }
    
      /**
       * Creates a table that uses the specified backing map and factory. It can generate a table based
       * on arbitrary {@link Map} classes.
       *
       * <p>The {@code factory}-generated and {@code backingMap} classes determine the table iteration
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * An executor service which forwards all its method calls to another executor service. Subclasses
     * should override one or more methods to modify the behavior of the backing executor service as
     * desired per the <a href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
     * <p><b>{@code default} method warning:</b> This class does <i>not</i> forward calls to {@code
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

                noMoreParts = true
                return null
              }
    
              2, 3 -> {
                // " " or "\t" Ignore whitespace and keep looking.
                whitespace = true
                continue@afterBoundaryLoop
              }
    
              -1 -> throw ProtocolException("unexpected characters after boundary")
            }
          }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/helper/CurlHelperTest.java

            curlHelper.init();
            CurlRequest request = curlHelper.get("/test");
    
            assertNotNull(request);
            // The request should be properly created - we can't easily verify headers without mocking framework
        }
    
        public void test_post() {
            setupMockConfig("localhost:9200", "", "");
    
            curlHelper.init();
            CurlRequest request = curlHelper.post("/test");
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 05:35:01 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

        // Break apart the domain into UTF-8 labels, i.e. foo.bar.com turns into [foo, bar, com].
        val domainLabelsUtf8Bytes = Array(domainLabels.size) { i -> domainLabels[i].encodeUtf8() }
    
        // Start by looking for exact matches. We start at the leftmost label. For example, foo.bar.com
        // will look like: [foo, bar, com], [bar, com], [com]. The longest matching rule wins.
        var exactMatch: String? = null
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

     * multiple routes to be attempted simultaneously.
     *
     * Events and sequences of events may be repeated for retries and follow-ups.
     *
     * All event methods must execute fast, without external locking, cannot throw exceptions, attempt
     * to mutate the event parameters, or be re-entrant back into the client. Any IO - writing to files
     * or network should be done asynchronously.
     */
    abstract class EventListener {
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link BlockingDeque} which forwards all its method calls to another {@code BlockingDeque}.
     * Subclasses should override one or more methods to modify the behavior of the backing deque as
     * desired per the <a href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
     * <p><b>Warning:</b> The methods of {@code ForwardingBlockingDeque} forward <b>indiscriminately</b>
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ForwardingMultiset.java

    import java.util.Set;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A multiset which forwards all its method calls to another multiset. Subclasses should override
     * one or more methods to modify the behavior of the backing multiset as desired per the <a
     * href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
     * <p><b>Warning:</b> The methods of {@code ForwardingMultiset} forward <b>indiscriminately</b> to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

                    }
                  });
          assertEquals("Counts not as expected", Ints.asList(deltas), actualCounts);
        } finally {
          pool.shutdownNow();
        }
    
        // Since we have access to the backing map, verify that there are no zeroes in the map
        for (AtomicInteger value : map.values()) {
          assertTrue("map should not contain a zero", value.get() != 0);
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 6K bytes
    - Viewed (0)
Back to top