- Sort Score
- Num 10 results
- Language All
Results 1 - 4 of 4 for propagation (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/util/concurrent/Futures.java
// methods that involve volatile read/write operations, in practice there is no issue. Also, the // way in such a visibility issue would surface is most likely as a failure of cancel() to // propagate to the input. Cancellation propagation is fundamentally racy so this is fine. // // Future versions of the JMM may revise safe construction semantics in such a way that we can // safely publish these objects and we won't need this whole discussion.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
internal/stmt_store/stmt_store.go
// error: An error if the statement preparation fails. func (s *lruStore) New(ctx context.Context, key string, isTransaction bool, conn ConnPool, locker sync.Locker) (_ *Stmt, err error) { // Create a Stmt object and set its Transaction property. // The prepared channel is used to synchronize the statement preparation state. cacheStmt := &Stmt{ Transaction: isTransaction,
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 6.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
* cancelled or set. * @since 19.0 */ @CanIgnoreReturnValue @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller. protected boolean setFuture(ListenableFuture<? extends V> future) { checkNotNull(future); @RetainedLocalRef Object localValue = value(); if (localValue == null) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} throw new AssertionError(status); } future.addListener(() -> provideValueAndCloser(consumer, this), executor); } @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller. boolean cancel(boolean mayInterruptIfRunning) { logger.get().log(FINER, "cancelling {0}", closingFutureToString()); boolean cancelled = future.cancel(mayInterruptIfRunning);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 101.7K bytes - Click Count (0)