Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 928 for happen (0.05 seconds)

  1. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

       * Futures#addCallback addCallback()}.
       *
       * <p>Memory consistency effects: Actions in a thread prior to adding a listener <a
       * href="https://docs.oracle.com/javase/specs/jls/se7/html/jls-17.html#jls-17.4.5">
       * <i>happen-before</i></a> its execution begins, perhaps in another thread.
       *
       * <p>Guava implementations of {@code ListenableFuture} promptly release references to listeners
       * after executing them.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  2. guava/src/com/google/common/util/concurrent/ListenableFuture.java

       * Futures#addCallback addCallback()}.
       *
       * <p>Memory consistency effects: Actions in a thread prior to adding a listener <a
       * href="https://docs.oracle.com/javase/specs/jls/se7/html/jls-17.html#jls-17.4.5">
       * <i>happen-before</i></a> its execution begins, perhaps in another thread.
       *
       * <p>Guava implementations of {@code ListenableFuture} promptly release references to listeners
       * after executing them.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  3. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          StringBuilder message = new StringBuilder(requireNonNull(super.getMessage()));
          for (Throwable t = conflictingStackTrace; t != null; t = t.getCause()) {
            message.append(", ").append(t.getMessage());
          }
          return message.toString();
        }
      }
    
      /**
       * Internal Lock implementations implement the {@code CycleDetectingLock} interface, allowing the
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 17:06:34 GMT 2025
    - 35.9K bytes
    - Click Count (0)
  4. cmd/admin-handlers-pools.go

    	}{ID: id})
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	writeSuccessResponseJSON(w, b)
    	// Notify peers to load rebalance.bin and start rebalance routine if they happen to be
    	// participating pool's leader node
    	globalNotificationSys.LoadRebalanceMeta(ctx, true)
    }
    
    func (a adminAPIHandlers) RebalanceStatus(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/base/SuppliersTest.java

        for (int i = 0; i < 2; i++) {
          try {
            memoizedSupplier.get();
            fail("failed to throw NullPointerException");
          } catch (NullPointerException e) {
            // this is what should happen
          }
        }
      }
    
      @J2ktIncompatible
      @GwtIncompatible // SerializableTester
      public void testMemoizeNonSerializable() throws Exception {
        CountingSupplier countingSupplier = new CountingSupplier();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/base/SuppliersTest.java

        for (int i = 0; i < 2; i++) {
          try {
            memoizedSupplier.get();
            fail("failed to throw NullPointerException");
          } catch (NullPointerException e) {
            // this is what should happen
          }
        }
      }
    
      @J2ktIncompatible
      @GwtIncompatible // SerializableTester
      public void testMemoizeNonSerializable() throws Exception {
        CountingSupplier countingSupplier = new CountingSupplier();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        assertThrows(IllegalArgumentException.class, () -> multiset.add(KEY, COUNT_TO_ADD));
      }
    
      /**
       * Simulate some of the races that can happen on add. We can't easily simulate the race that
       * happens when an {@link AtomicInteger#compareAndSet} fails, but we can simulate the case where
       * the putIfAbsent returns a non-null value, and the case where the replace() of an observed zero
       * fails.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 08 22:42:14 GMT 2025
    - 16.3K bytes
    - Click Count (0)
  8. docs/distributed/DESIGN.md

                    atTotal += pool.Available
                    if atTotal > choose && pool.Available > 0 {
                            return pool.Index
                    }
            }
            // Should not happen, but print values just in case.
            panic(fmt.Errorf("reached end of serverPools (total: %v, atTotal: %v, choose: %v)", total, atTotal, choose))
    }
    ```
    
    ## Other usages
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 8K bytes
    - Click Count (2)
  9. src/cmd/asm/internal/lex/input.go

    	var tokens []Token
    	for _, tok := range macro.tokens {
    		if tok.ScanToken != scanner.Ident {
    			tokens = append(tokens, tok)
    			continue
    		}
    		substitution := actuals[tok.text]
    		if substitution == nil {
    			tokens = append(tokens, tok)
    			continue
    		}
    		tokens = append(tokens, substitution...)
    	}
    	in.Push(NewSlice(in.Base(), in.Line(), tokens))
    }
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Nov 12 03:59:40 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  10. src/cmd/asm/internal/asm/parse.go

    				}
    				break
    			}
    			if tok == '(' || tok == '[' {
    				nesting++
    			}
    			if tok == ')' || tok == ']' {
    				nesting--
    			}
    			items = append(items, lex.Make(tok, p.lex.Text()))
    		}
    		if len(items) > 0 {
    			operands = append(operands, items)
    			if colon >= 0 && len(operands) == colon+2 {
    				// AX:DX becomes DX, AX.
    				operands[colon], operands[colon+1] = operands[colon+1], operands[colon]
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Nov 12 03:59:40 GMT 2025
    - 37.3K bytes
    - Click Count (0)
Back to Top