Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 126 for observed (0.03 sec)

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

            }
          }
          return;
        }
    
        /*
         * This is an unsynchronized read! After the read, the function returns immediately or acquires
         * the lock to check again. Since an IDLE state was observed inside the preceding synchronized
         * block, and reference field assignment is atomic, this may save reacquiring the lock when
         * another thread or the worker task has cleared the count and set the state.
         *
    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/util/concurrent/TimeoutFuture.java

       *
       * The initial write to delegateRef is made definitely visible via the semantics of
       * addListener/SES.schedule. The later racy write in cancel() is not guaranteed to be observed,
       * however that is fine since the correctness is based on the atomic state in our base class. The
       * initial write to timer is never definitely visible to Fire.run since it is assigned after
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                }
              };
          executor.execute(errorTask);
          service.execute(barrierTask); // submit directly to the service
          // the barrier task runs after the error task so we know that the error has been observed by
          // SequentialExecutor by the time the barrier is satisfied
          barrier.await(1, SECONDS);
          executor.execute(barrierTask);
          // timeout means the second task wasn't even tried
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt

        server.requireClientAuth()
        val call = client.newCall(Request.Builder().url(server.url("/")).build())
        assertFailsWith<IOException> {
          call.execute()
        }
    
        // Observed Events are variable
        // JDK 14
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/MapMaker.java

       * table is internally partitioned to try to permit the indicated number of concurrent updates
       * without contention. Because assignment of entries to these partitions is not necessarily
       * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

            }
          } finally {
            monitor.leave();
          }
        }
    
        /**
         * Marks the {@link State} as ready to receive transitions. Returns true if no transitions have
         * been observed yet.
         */
        void markReady() {
          monitor.enter();
          try {
            if (!transitioned) {
              // nothing has transitioned since construction, good.
              ready = true;
            } else {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_4x.md

        Typically this would cause certain redirects to fail in debug and development configurations.
    
    
    ## Version 4.4.0
    
    _2020-02-17_
    
     *  New: Support `canceled()` as an event that can be observed by `EventListener`. This should be
        useful for splitting out canceled calls in metrics.
    
     *  New: Publish a [bill of materials (BOM)][bom] for OkHttp. Depend on this from Gradle or Maven to
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/net/InetAddresses.java

     *   <dt>An IPv6 "IPv4 mapped" address, {@code "::ffff:192.168.0.1"}.
     *   <dd>{@code 00 00 00 00 00 00 00 00 00 00 ff ff c0 a8 00 01}
     * </dl>
     *
     * <p>A few notes about IPv6 "IPv4 mapped" addresses and their observed use in Java.
     *
     * <p>"IPv4 mapped" addresses were originally a representation of IPv4 addresses for use on an IPv6
     * socket that could receive both IPv4 and IPv6 connections (by disabling the {@code IPV6_V6ONLY}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 47.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/CacheBuilder.java

       * table is internally partitioned to try to permit the indicated number of concurrent updates
       * without contention. Because assignment of entries to these partitions is not necessarily
       * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
       * accommodate as many threads as will ever concurrently modify the table. Using a significantly
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

          }
    
          return value;
        }
    
        /**
         * Performs routine cleanup following a read. Normally cleanup happens during writes, or from
         * the cleanupExecutor. If cleanup is not observed after a sufficient number of reads, try
         * cleaning up from the read thread.
         */
        void postReadCleanup() {
          if ((readCount.incrementAndGet() & DRAIN_THRESHOLD) == 0) {
            runCleanup();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
Back to top