- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 82 for intercept (0.15 sec)
-
android/guava-testlib/test/com/google/common/collect/testing/MapTestSuiteBuilderTests.java
* {@code setUpRan} parameter is set true by the {@code setUp} that every test case is supposed to * have registered, and set false by the {@code tearDown}. We use a dynamic proxy to intercept all * of the {@code Map} method calls and check that {@code setUpRan} is true. */ private static class CheckSetUpHashMapGenerator extends WrappedHashMapGenerator { private final AtomicBoolean setUpRan;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 11.5K bytes - Viewed (0) -
guava-testlib/test/com/google/common/collect/testing/MapTestSuiteBuilderTests.java
* {@code setUpRan} parameter is set true by the {@code setUp} that every test case is supposed to * have registered, and set false by the {@code tearDown}. We use a dynamic proxy to intercept all * of the {@code Map} method calls and check that {@code setUpRan} is true. */ private static class CheckSetUpHashMapGenerator extends WrappedHashMapGenerator { private final AtomicBoolean setUpRan;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 11.9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/TestLogHandler.java
import java.util.Collections; import java.util.List; import java.util.logging.Handler; import java.util.logging.LogRecord; import org.checkerframework.checker.nullness.qual.Nullable; /** * Tests may use this to intercept messages that are logged by the code under test. Example: * * <pre> * TestLogHandler handler; * * protected void setUp() throws Exception { * super.setUp(); * handler = new TestLogHandler();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 2.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/TestLogHandler.java
import java.util.Collections; import java.util.List; import java.util.logging.Handler; import java.util.logging.LogRecord; import org.checkerframework.checker.nullness.qual.Nullable; /** * Tests may use this to intercept messages that are logged by the code under test. Example: * * <pre> * TestLogHandler handler; * * protected void setUp() throws Exception { * super.setUp(); * handler = new TestLogHandler();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 26 20:07:17 GMT 2023 - 2.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
* 3. We expect the client's get() to throw an InterruptedException. * 4. We expect the client thread's interrupt state to be false. * 5. The client thread again makes a blocking call to get(). * 6. Now the result becomes available. * 7. We expect get() to return this result. * 8. We expect the test thread's interrupt state to be false. */ InterruptionUtil.requestInterruptIn(200, TimeUnit.MILLISECONDS);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
} task = queue.poll(); if (task == null) { workerRunningState = IDLE; return; } } // Remove the interrupt bit before each task. The interrupt is for the "current task" when // it is sent, so subsequent tasks in the queue should not be caused to be interrupted // by a previous one in the queue being interrupted.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
return lock.tryLock(remainingNanos, TimeUnit.NANOSECONDS); } catch (InterruptedException interrupt) { interrupted = true; remainingNanos = remainingNanos(startTime, timeoutNanos); } } } finally { if (interrupted) { Thread.currentThread().interrupt(); } } } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Dec 04 18:22:01 GMT 2023 - 38.6K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheLoader.java
* @throws InterruptedException if this method is interrupted. {@code InterruptedException} is * treated like any other {@code Exception} in all respects except that, when it is caught, * the thread's interrupt status is set */ public abstract V load(K key) throws Exception; /** * Computes or retrieves a replacement value corresponding to an already-cached {@code key}. This
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 19 20:20:14 GMT 2022 - 9.6K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Ascii.java
* Device Control 1. Characters for the control of ancillary devices associated with data * processing or telecommunication systems, more especially switching devices "on" or "off." (If a * single "stop" control is required to interrupt or turn off ancillary devices, DC4 is the * preferred assignment.) * * @since 8.0 */ public static final byte DC1 = 17; // aka XON /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Jul 19 15:43:07 GMT 2021 - 21.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
new Runnable() { @Override public void run() { try { okayToRun.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new RuntimeException(e); } runCalled.getAndIncrement(); } }, directExecutor()); Runnable execute = new Runnable() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 4.7K bytes - Viewed (0)