- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 253 for blocks (0.15 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
* future. * * <ul> * <li>SafeAtomicHelper: uses AtomicReferenceFieldsUpdaters to implement synchronization * <li>SynchronizedHelper: uses {@code synchronized} blocks for synchronization * </ul> * * To force selection of our fallback strategies we load {@link AbstractFuture} (and all of {@code * com.google.common.util.concurrent}) in degenerate class loaders which make certain platform
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 6.2K bytes - Viewed (0) -
docs/features/calls.md
Calls are executed in one of two ways: * **Synchronous:** your thread blocks until the response is readable. * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
/* * Using weak references here could let us release exceptions earlier, but: * * 1. On Android, querying a WeakReference blocks if the GC is doing an otherwise-concurrent * pass. * * 2. We would probably choose to compare exceptions using == instead of equals() (for
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 8.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
/** * Invoked to request the service to stop. * * <p>By default this method does nothing. * * <p>Currently, this method is invoked while holding a lock. If an implementation of this method * blocks, it can prevent this service from changing state. If you need to performing a blocking * operation in order to trigger shutdown, consider instead registering a listener and
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 7.6K bytes - Viewed (0) -
internal/crypto/doc.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. // Package crypto implements AWS S3 related cryptographic building blocks // for implementing Server-Side-Encryption (SSE-S3) and Server-Side-Encryption // with customer provided keys (SSE-C). // // All objects are encrypted with an unique and randomly generated 'ObjectKey'.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Aug 26 19:52:29 GMT 2022 - 5K bytes - Viewed (0) -
internal/s3select/csv/reader.go
return dst, io.EOF } } // Read until next line. in, err := r.buf.ReadBytes('\n') dst = append(dst, in...) return dst, err } // csvSplitSize is the size of each block. // Blocks will read this much and find the first following newline. // 128KB appears to be a very reasonable default. const csvSplitSize = 128 << 10 // startReaders will read the header if needed and spin up a parser
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/event/target/nsq.go
return target.store.Del(key.Name) } // Close - closes underneath connections to NSQD server. func (target *NSQTarget) Close() (err error) { close(target.quitCh) if target.producer != nil { // this blocks until complete: target.producer.Stop() } return nil } func (target *NSQTarget) init() error { return target.initOnce.Do(target.initNSQ) } func (target *NSQTarget) initNSQ() error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
* Fix: Eliminate rare race condition in SPDY streams that would prevent connection reuse. * Fix: Change HTTP date formats to UTC to conform to RFC2616 section 3.3. * Fix: Support SPDY header blocks with trailing bytes. * Fix: Allow `;` as separator for `Cache-Control` header. * Fix: Correct bug where HTTPS POST requests were always automatically buffered. * Fix: Honor read timeout when parsing SPDY headers.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 6.4K bytes - Viewed (0) -
build-logic-commons/code-quality-rules/src/main/resources/checkstyle/checkstyle.xml
</module> <!-- allows suppressing using the @SuppressWarnings("checkstyle:...") --> <module name="SuppressWarningsFilter"/> <module name="TreeWalker"> <!-- Blocks --> <module name="EmptyBlock"> <property name="option" value="statement"/>
XML - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Dec 16 22:05:16 GMT 2022 - 6.3K bytes - Viewed (0) -
docs/en/docs/tutorial/index.md
It is also built to work as a future reference. So you can come back and see exactly what you need. ## Run the code All the code blocks can be copied and used directly (they are actually tested Python files). To run any of the examples, copy the code to a file `main.py`, and start `fastapi dev` with: <div class="termy"> ```console
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu May 02 22:37:31 GMT 2024 - 5.9K bytes - Viewed (0)