- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 126 for observed (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (0) -
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) -
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) -
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) -
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)