- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 102 for trigger (0.26 sec)
-
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* of {@link CombinedFuture}, the user-supplied callback usually has its own references to inputs. */ /* * In certain circumstances, this field might theoretically not be visible to an afterDone() call * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture. */ @CheckForNull @LazyInit private ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 15.4K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/primitives/UnsignedLongsBenchmark.java
} // A random value that cannot be 0 and that is unsigned-less-than or equal // to the given dividend, so that we don't have half of our divisions being // trivial because the divisor is bigger than the dividend. // Using remainder here does not give us a uniform distribution but it should // not have a big impact on the measurement. private static long randomDivisor(long dividend) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* to timer, and importantly this is the main situation in which we need to be able to see the * write. * * 2. visibility of the writes to an afterDone() call triggered by cancel(): * * Since these fields are non-final that means that TimeoutFuture is not being 'safely published', * thus a motivated caller may be able to expose the reference to another thread that would then
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
LocalCache<String, String> cache = makeLocalCache(builder, loader); assertThat(cache.getOrLoad("test")).isEqualTo("testLoad"); ticker.advance(10, MILLISECONDS); // so that the next call will trigger refresh assertThat(cache.getOrLoad("test")).isEqualTo("testLoad"); reloadStarted.await(); ticker.advance(500, MILLISECONDS); // so that the entry expires during the reload
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 112.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
LocalCache<String, String> cache = makeLocalCache(builder, loader); assertThat(cache.getOrLoad("test")).isEqualTo("testLoad"); ticker.advance(10, MILLISECONDS); // so that the next call will trigger refresh assertThat(cache.getOrLoad("test")).isEqualTo("testLoad"); reloadStarted.await(); ticker.advance(500, MILLISECONDS); // so that the entry expires during the reload
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 110.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
// // Except for (c), every thread should occupy the monitor very briefly, and every thread leaves // the monitor with the guard satisfied. Therefore as soon as tearDownLatch is triggered, we // should be able to enter the monitor, and then we set the guard to satisfied for the benefit // of any remaining waiting threads. tearDownLatch.countDown(); assertTrue(
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) -
guava-tests/test/com/google/common/reflect/TypeTokenTest.java
} public <T> void testVariableTypeTokenNotAllowed() { /* * We'd use assertThrows here, but that causes no exception to be thrown under Java 8, * presumably because the ThrowingRunnable lambda triggers some kind of bug in Java 8's * reflection implementation. */ try { new TypeToken<T>() {}; fail(); } catch (IllegalStateException expected) { } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 88.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
* performed in the order they were provided to the constructor. Verify * that as a sanity check: */ assertFalse(future2.isCancelled()); // Now attempt to trigger the exception: future2.set(DATA2); } }, directExecutor()); assertTrue(compound.cancel(false)); assertTrue(compound.isCancelled());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/NtlmAuthenticator.java
If this method returns <tt>null</tt> the <tt>SmbAuthException</tt> that triggered the authenticator check will simply be rethrown. The default implementation returns <tt>null</tt>. */ protected NtlmPasswordAuthentication getNtlmPasswordAuthentication() { return null; }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 2.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
waitingThread.interrupt(); } future.set(RESULT); assertEquals(times > 0, (boolean) interruptReporter.get(20, SECONDS)); } /** * Confirms that the test code triggers {@link InterruptedException} in a standard {@link Future}. */ public void testMakeUninterruptible_plainFutureSanityCheck() throws Exception { SettableFuture<String> future = SettableFuture.create();
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)