- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 125 for Block (0.14 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
manager.addListener( new ServiceManager.Listener() { @Override public void failure(Service service) { failEnter.countDown(); // block until after the service manager is shutdown Uninterruptibles.awaitUninterruptibly(failLeave); } }, directExecutor()); manager.startAsync(); afterStarted.countDown();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
}; Thread runner = new Thread(task, "runner"); runner.start(); isInterruptibleRegistered.await(); // trigger the interrupt on another thread since it will block Thread interrupter = new Thread("Interrupter") { @Override public void run() { task.interruptTask(); } }; interrupter.start();
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/src/com/google/common/io/CharStreams.java
total += read; Java8Compatibility.clear(buf); } return total; } /** * Discards {@code n} characters of data from the reader. This method will block until the full * amount has been skipped. Does not close the reader. * * @param reader the reader to read from * @param n the number of characters to skip
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 10.9K bytes - Viewed (0) -
guava/src/com/google/common/base/Predicates.java
* future changes to it will alter the behavior of the predicate. * * <p>This method can technically accept any {@code Collection<?>}, but using a typed collection * helps prevent bugs. This approach doesn't block any potential users since it is always possible * to use {@code Predicates.<Object>in()}. * * @param target the collection that may contain the function input */
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Feb 09 15:49:48 GMT 2024 - 23.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
return method.getName().startsWith("enter") || method.getName().startsWith("tryEnter"); } /** Identifies just tryEnterXxx methods (a subset of {@link #isAnyEnter}), which never block. */ private static boolean isTryEnter(Method method) { return method.getName().startsWith("tryEnter"); } /**
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 14:48:57 GMT 2023 - 27.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSource.java
* that provide readers that are: * * <ul> * <li><b>Finite:</b> Many operations, such as {@link #length()} and {@link #read()}, will either * block indefinitely or fail if the source creates an infinite reader. * <li><b>Non-destructive:</b> A <i>destructive</i> reader will consume or otherwise alter the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 22.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
: t; releaseShared(finalState); } else if (getState() == COMPLETING) { // If some other thread is currently completing the future, block until // they are done so we can guarantee completion. acquireShared(-1); } return doCompletion; } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed May 09 15:17:25 GMT 2018 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
: t; releaseShared(finalState); } else if (getState() == COMPLETING) { // If some other thread is currently completing the future, block until // they are done so we can guarantee completion. acquireShared(-1); } return doCompletion; } }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteSource.java
* that provide streams that are: * * <ul> * <li><b>Finite:</b> Many operations, such as {@link #size()} and {@link #read()}, will either * block indefinitely or fail if the source creates an infinite stream. * <li><b>Non-destructive:</b> A <i>destructive</i> stream will consume or otherwise alter the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 26.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
MEDIUM_DELAY_MS = SHORT_DELAY_MS * 10; LONG_DELAY_MS = SHORT_DELAY_MS * 200; } /** * Returns a timeout in milliseconds to be used in tests that verify that operations block or time * out. */ long timeoutMillis() { return SHORT_DELAY_MS / 4; } /** Returns a new Date instance representing a time delayMillis milliseconds in the future. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0)