Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for propagation (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to Top