- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 334 for LOOP (0.12 sec)
-
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
.hasMessageThat() .isEqualTo("I bet you didn't think Thread.interrupt could throw"); // We need to wait for the runner to exit. It used to be that the runner would get stuck in the // busy loop when interrupt threw. runner.join(TimeUnit.SECONDS.toMillis(10)); } static final class BrokenChannel extends AbstractInterruptibleChannel { @Override protected void implCloseChannel() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ForwardingNavigableMapTest.java
public @Nullable Entry<K, V> firstEntry() { return standardFirstEntry(); } /* * We can't override lastEntry to delegate to standardLastEntry, as it would create an infinite * loop. Instead, we test standardLastEntry manually below. */ @Override public @Nullable Entry<K, V> pollFirstEntry() { return standardPollFirstEntry(); } @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 9.5K bytes - Viewed (0) -
cmd/leak-detect_test.go
} // DetectLeak - Creates a snapshot of runtime stack and compares it with the initial stack snapshot. func (initialSnapShot LeakDetect) DetectLeak(t TestErrHandler) { if t.Failed() { return } // Loop, waiting for goroutines to shut down. // Wait up to 5 seconds, but finish as quickly as possible. deadline := UTCNow().Add(leakDetectDeadline * time.Second) for { // get sack snapshot of relevant go routines.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Protocol.kt
* * @throws IOException if `protocol` is unknown. */ @JvmStatic @Throws(IOException::class) fun get(protocol: String): Protocol { // Unroll the loop over values() to save an allocation. @Suppress("DEPRECATION") return when (protocol) { HTTP_1_0.protocol -> HTTP_1_0 HTTP_1_1.protocol -> HTTP_1_1
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:17:33 GMT 2024 - 4.4K bytes - Viewed (1) -
guava-tests/test/com/google/common/graph/AbstractNetworkTest.java
"Collection returned is unexpectedly modifiable"; static final String ERROR_SELF_LOOP = "self-loops are not allowed"; static final String ERROR_EDGE_NOT_IN_GRAPH = "Should not be allowed to pass an edge that is not an element of the graph."; static final String ERROR_ADDED_SELF_LOOP = "Should not be allowed to add a self-loop edge."; static final String ERROR_ADDED_PARALLEL_EDGE = "Should not be allowed to add a parallel edge.";
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Jan 22 17:29:38 GMT 2024 - 33K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/graph/AbstractNetworkTest.java
"Collection returned is unexpectedly modifiable"; static final String ERROR_SELF_LOOP = "self-loops are not allowed"; static final String ERROR_EDGE_NOT_IN_GRAPH = "Should not be allowed to pass an edge that is not an element of the graph."; static final String ERROR_ADDED_SELF_LOOP = "Should not be allowed to add a self-loop edge."; static final String ERROR_ADDED_PARALLEL_EDGE = "Should not be allowed to add a parallel edge.";
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Jan 22 17:29:38 GMT 2024 - 32.7K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/ValueGraphBuilder.java
return new ImmutableValueGraph.Builder<>(castBuilder); } /** * Specifies whether the graph will allow self-loops (edges that connect a node to itself). * Attempting to add a self-loop to a graph that does not allow them will throw an {@link * UnsupportedOperationException}. * * <p>The default value is {@code false}. */ @CanIgnoreReturnValue
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Jun 03 01:21:31 GMT 2022 - 8K bytes - Viewed (0) -
cmd/callhome.go
// will keep performing the callhome. If the leader goes down for some reason, // the lock will be released and another node will acquire it and take over // because of this loop. for { if !globalCallhomeConfig.Enabled() { return } if !runCallhome(ctx, objAPI) { // callhome was disabled or context was canceled return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
protected void startUp() throws Exception {} /** * Run the service. This method is invoked on the execution thread. Implementations must respond * to stop requests. You could poll for lifecycle changes in a work loop: * * <pre> * public void run() { * while ({@link #isRunning()}) { * // perform a unit of work * } * } * </pre> *
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) -
guava-tests/test/com/google/common/collect/ForwardingNavigableMapTest.java
public @Nullable Entry<K, V> firstEntry() { return standardFirstEntry(); } /* * We can't override lastEntry to delegate to standardLastEntry, as it would create an infinite * loop. Instead, we test standardLastEntry manually below. */ @Override public @Nullable Entry<K, V> pollFirstEntry() { return standardPollFirstEntry(); } @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 9.5K bytes - Viewed (0)