- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,085 for findall (0.16 sec)
-
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} @J2ktIncompatible @GwtIncompatible // blocking wait public void testCancel_interrupted() throws Exception { final AtomicBoolean interruptedExceptionThrown = new AtomicBoolean(); final CountDownLatch enterLatch = new CountDownLatch(1); final CountDownLatch exitLatch = new CountDownLatch(1); final TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create( new Callable<Integer>() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 7.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
} private ListenerCallQueue.Event<Object> incrementingEvent( final Multiset<Object> counters, final Multiset<Object> expected) { return new ListenerCallQueue.Event<Object>() { @Override public void call(Object listener) { counters.add(listener); assertEquals(expected.count(listener), counters.count(listener)); } @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
final Monitor monitor, boolean expectedIsOccupied, boolean expectedIsOccupiedByCurrentThread, int expectedOccupiedDepth) { final AtomicBoolean actualIsOccupied = new AtomicBoolean(); final AtomicBoolean actualIsOccupiedByCurrentThread = new AtomicBoolean(); final AtomicInteger actualOccupiedDepth = new AtomicInteger();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.9K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/TearDownStackTest.java
} public void testMultipleTearDownsHappenInOrder() throws Exception { final TearDownStack stack = buildTearDownStack(); final SimpleTearDown tearDownOne = new SimpleTearDown(); stack.addTearDown(tearDownOne); final Callback callback = new Callback() { @Override public void run() { assertEquals(
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 4.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/ReentrantEventsTest.java
* * @author Jesse Wilson */ public class ReentrantEventsTest extends TestCase { static final String FIRST = "one"; static final Double SECOND = 2.0d; final EventBus bus = new EventBus(); public void testNoReentrantEvents() { ReentrantEventsHater hater = new ReentrantEventsHater(); bus.register(hater); bus.post(FIRST);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closeables.java
@J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public final class Closeables { @VisibleForTesting static final Logger logger = Logger.getLogger(Closeables.class.getName()); private Closeables() {} /** * Closes a {@link Closeable}, with control over whether an {@code IOException} may be thrown. * This is primarily useful in a finally block, where a thrown exception needs to be logged but
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
return null; } }; Callables.threadRenaming(callable, newName).call(); assertEquals(oldName, Thread.currentThread().getName()); } finally { System.setSecurityManager(null); } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteSourceTester.java
assertExpectedBytes(readBytes); } finally { in.close(); } } public void testOpenBufferedStream() throws IOException { InputStream in = source.openBufferedStream(); try { byte[] readBytes = ByteStreams.toByteArray(in); assertExpectedBytes(readBytes); } finally { in.close(); } }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 8.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
helperField.setAccessible(true); assertEquals(expectedHelperClassName, helperField.get(null).getClass().getSimpleName()); } private static ClassLoader getClassLoader(final Set<String> blocklist) { final String concurrentPackage = SettableFuture.class.getPackage().getName(); ClassLoader classLoader = AggregateFutureStateFallbackAtomicHelperTest.class.getClassLoader();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 5.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* started execution. It is unclear from the {@code ExecutorService} specification if these should * be included, and it's much easier to implement the interpretation that they not be. Finally, a * call to {@code shutdown} or {@code shutdownNow} may result in concurrent calls to {@code * invokeAll/invokeAny} throwing RejectedExecutionException, although a subset of the tasks may * already have been executed.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0)