- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 5,078 for uses (0.03 seconds)
-
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
// For these users fallback to a suboptimal implementation, based on synchronized. This will // be a definite performance hit to those users. thrownReflectionFailure = reflectionFailure; helper = new SynchronizedAtomicHelper(); } ATOMIC_HELPER = helper; // Log after all static init is finished; if an installed logger uses any Futures methods, itCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 8.5K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* methods. This class uses a single thread to execute the service; consider {@link AbstractService} * if you would like to manage any threading manually. * * @author Jesse Wilson * @since 1.0 */ @GwtIncompatible @J2ktIncompatible public abstract class AbstractExecutionThreadService implements Service { /* use AbstractService for state management */ private final Service delegate =Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 7.5K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/EnrichedReportRenderer.groovy
return result; } function appendErrorCorrections(reason) { var result = JSON.parse('${currentApiChanges.replace('\n', '')}'); // JSON string from report uses double quotes, contain it within single quotes getAllErrorCorrections().forEach((correction) => { correction.acceptation = reason;Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Feb 07 20:38:43 GMT 2023 - 7.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
assertThat(object).isNotNull(); assertSame(object, striped.getAt(i)); // idempotent observed.add(object); } assertTrue("All stripes observed", observed.size() == striped.size()); // this uses #get(key), makes sure an already observed stripe is returned for (int i = 0; i < striped.size() * 100; i++) { assertTrue(observed.contains(striped.get(new Object()))); } try {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:19:59 GMT 2025 - 8.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
assertThat(object).isNotNull(); assertSame(object, striped.getAt(i)); // idempotent observed.add(object); } assertTrue("All stripes observed", observed.size() == striped.size()); // this uses #get(key), makes sure an already observed stripe is returned for (int i = 0; i < striped.size() * 100; i++) { assertTrue(observed.contains(striped.get(new Object()))); } try {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:19:59 GMT 2025 - 8.5K bytes - Click Count (0) -
docs/changelogs/changelog_3x.md
This increases the likelihood that HTTP/2 connections will be shared. * New: Authentication challenges and credentials now use a charset. Use this in your authenticator to support user names and passwords with non-ASCII characters. * New: Accept a charset in `FormBody.Builder`. Previously form bodies were always UTF-8.Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Click Count (0) -
mockwebserver/README.md
assertEquals("application/json; charset=utf-8", request.headers["Content-Type"]) assertEquals("{}", request.body!!.utf8()) ``` #### Dispatcher By default MockWebServer uses a queue to specify a series of responses. Use a Dispatcher (`import okhttp3.mockwebserver.Dispatcher`) to handle requests using another policy. One natural policy is to dispatch on the request path.Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 21:39:59 GMT 2025 - 8.1K bytes - Click Count (0) -
src/archive/tar/reader.go
// The sparse map is stored in the tar header if it's small enough. // If it's larger than four entries, then one or more extension headers are used // to store the rest of the sparse map. // // The Header.Size does not reflect the size of any extended headers used. // Thus, this function will read from the raw io.Reader to fetch extra headers. // This method mutates blk in the process.
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Oct 07 19:46:36 GMT 2025 - 26.9K bytes - Click Count (0) -
internal/bucket/lifecycle/expiration.go
DeleteMarker ExpireDeleteMarker `xml:"ExpiredObjectDeleteMarker"` // Indicates whether MinIO will remove all versions. If set to true, all versions will be deleted; // if set to false the policy takes no action. This action uses the Days/Date to expire objects. // This check is verified for latest version of the object. DeleteAll Boolean `xml:"ExpiredObjectAllVersions"` set bool }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 6.6K bytes - Click Count (0) -
docs/en/docs/deployment/manually.md
# Run a Server Manually { #run-a-server-manually } ## Use the `fastapi run` Command { #use-the-fastapi-run-command } In short, use `fastapi run` to serve your FastAPI application: <div class="termy"> ```console $ <font color="#4E9A06">fastapi</font> run <u style="text-decoration-style:solid">main.py</u> <span style="background-color:#009485"><font color="#D3D7CF"> FastAPI </font></span> Starting production server 🚀Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 6.9K bytes - Click Count (0)