- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 928 for happen (0.05 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
docs/distributed/DESIGN.md
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Feb 26 09:25:50 GMT 2025 - 8K bytes - Click Count (2) -
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) -
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)