Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 221 - 230 of 311 for Celery (0.05 seconds)

  1. internal/lru/lru.go

    //
    // Size parameter set to 0 makes cache of unlimited size, e.g. turns LRU mechanism off.
    //
    // Providing 0 TTL turns expiring off.
    //
    // Delete expired entries every 1/100th of ttl value. Goroutine which deletes expired entries runs indefinitely.
    func NewLRU[K comparable, V any](size int, onEvict EvictCallback[K, V], ttl time.Duration) *LRU[K, V] {
    	if size < 0 {
    		size = 0
    	}
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  2. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

       * @return an array containing all of the elements in this queue
       * @throws ArrayStoreException if the runtime type of the specified array is not a supertype of
       *     the runtime type of every element in this queue
       * @throws NullPointerException if the specified array is null
       */
      @CanIgnoreReturnValue
      @Override
      public <T> T[] toArray(T[] a) {
        E[] items = this.items;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  3. guava-testlib/src/com/google/common/testing/AbstractPackageSanityTests.java

          } catch (Throwable e) {
            throw sanityError(classToTest, NULL_TEST_METHOD_NAMES, "nulls test", e);
          }
        }
      }
    
      /**
       * Tests {@code equals()} and {@code hashCode()} implementations for every top-level class in the
       * package, that explicitly implements {@link Object#equals}. For a class {@code C}:
       *
       * <ul>
       *   <li>The visible constructor or visible static factory method with the most parameters is used
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/hash/HashTestUtils.java

       */
      static void checkNo2BitCharacteristics(HashFunction function) {
        Random rand = new Random(0);
        int keyBits = 32;
    
        // get every one of (keyBits choose 2) deltas:
        for (int i = 0; i < keyBits; i++) {
          for (int j = 0; j < keyBits; j++) {
            if (j <= i) continue;
            int count = 0;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 25.6K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/Collections2.java

       * the underlying collection.
       *
       * <p>The returned collection isn't threadsafe or serializable, even if {@code unfiltered} is.
       *
       * <p>Many of the filtered collection's methods, such as {@code size()}, iterate across every
       * element in the underlying collection and determine which elements satisfy the filter. When a
       * live view is <i>not</i> needed, it may be faster to copy {@code Iterables.filter(unfiltered,
       * predicate)} and use the copy.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 22.6K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        assertThat(server.receivedPingCount()).isEqualTo(0)
        assertThat(server.receivedPongCount()).isEqualTo(0)
        closeWebSockets(webSocket, server)
      }
    
      /**
       * Configure the websocket to send pings every 500 ms. Artificially prevent the server from
       * responding to pings. The client should give up when attempting to send its 2nd ping, at about
       * 1000 ms.
       */
      @Test
      fun unacknowledgedPingFailsConnection() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  7. CONTRIBUTING.md

    If your PR includes any changes to the Gradle Public API, it will cause the binary compatibility check to fail.
    The binary compatibility check runs as a part of the broader sanity check.
    The latter runs on every PR and is a prerequisite for merging.
    
    If you run the sanity check locally with the `./gradlew sanityCheck`, you can see the binary compatibility error in the output.
    It looks like the following:
    
    ```
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Nov 25 06:57:22 GMT 2025
    - 19K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/math/DoubleMathTest.java

          }
        }
      }
    
      @GwtIncompatible // DoubleMath.roundToLong(double, RoundingMode)
      public void testRoundExactIntegralDoubleToLong() {
        for (double d : INTEGRAL_DOUBLE_CANDIDATES) {
          // every mode except UNNECESSARY
          BigDecimal expected = new BigDecimal(d).setScale(0, UNNECESSARY);
          boolean isInBounds =
              expected.compareTo(MAX_LONG_AS_BIG_DECIMAL) <= 0
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Oct 30 14:15:36 GMT 2025
    - 27.3K bytes
    - Click Count (0)
  9. guava/src/com/google/common/math/LongMath.java

             *
             * We carry out this computation in modular arithmetic. Since times2ToThe32Mod accepts any
             * unsigned long, we don't have to do a mod on every operation, only when intermediate
             * results can exceed 2^63.
             */
            long result = times2ToThe32Mod(aHi * bHi /* < 2^62 */, m); // < m < 2^63
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Nov 03 21:01:09 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  10. LICENSES/vendor/cyphar.com/go-pathrs/LICENSE

    behalf of any Contributor. You must make it absolutely clear that any
    such warranty, support, indemnity, or liability obligation is offered by
    You alone, and You hereby agree to indemnify every Contributor for any
    liability incurred by such Contributor as a result of warranty, support,
    indemnity or liability terms You offer. You may include additional
    disclaimers of warranty and limitations of liability specific to any
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Wed Nov 12 14:46:31 GMT 2025
    - 16.5K bytes
    - Click Count (0)
Back to Top