- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for haon (0.16 sec)
-
guava-tests/test/com/google/common/base/SuppliersTest.java
private static final long serialVersionUID = 0L; } static void checkMemoize(CountingSupplier countingSupplier, Supplier<Integer> memoizedSupplier) { // the underlying supplier hasn't executed yet assertEquals(0, countingSupplier.calls); assertEquals(10, (int) memoizedSupplier.get()); // now it has assertEquals(1, countingSupplier.calls);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri Feb 09 15:49:48 GMT 2024 - 18.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/SuppliersTest.java
private static final long serialVersionUID = 0L; } static void checkMemoize(CountingSupplier countingSupplier, Supplier<Integer> memoizedSupplier) { // the underlying supplier hasn't executed yet assertEquals(0, countingSupplier.calls); assertEquals(10, (int) memoizedSupplier.get()); // now it has assertEquals(1, countingSupplier.calls);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri Feb 09 15:49:48 GMT 2024 - 18.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
} } } } private void waitForInterrupt(Thread currentThread) { /* * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet. * Wait for the interrupting thread to set DONE. (See interruptTask().) We want to wait so that * the interrupting thread doesn't interrupt the _next_ thing to run on this thread. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Sep 29 21:34:48 GMT 2023 - 9.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
* thread calls this method, which waits until the service has performed * its own "running" check. */ void awaitRunChecks() throws InterruptedException { assertTrue( "Service thread hasn't finished its checks. " + "Exception status (possibly stale): " + thrownByExecutionThread, hasConfirmedIsRunning.await(10, SECONDS)); } @Override
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 29.3K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/ReactorReader.java
import org.slf4j.LoggerFactory; /** * An implementation of a workspace reader that knows how to search the Maven reactor for artifacts, either as packaged * jar if it has been built, or only compile output directory if packaging hasn't happened yet. * */ @Named(ReactorReader.HINT) @SessionScoped class ReactorReader implements MavenWorkspaceReader { public static final String HINT = "reactor";
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 21.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/CompactHashSet.java
Object newTable = CompactHashing.createTable(newCapacity); int newMask = newCapacity - 1; if (targetEntryIndex != UNSET) { // Add target first; it must be last in the chain because its entry hasn't yet been created CompactHashing.tableSet(newTable, targetHash & newMask, targetEntryIndex + 1); } Object oldTable = requireTable(); int[] entries = requireEntries();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Feb 05 21:38:59 GMT 2024 - 24K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/HashBiMap.java
HashBiMap.this.put(key, value); return unsafeNull(); // See the discussion in getValue(). } /* * The cast is safe because updateIndex found the entry for this key. (If it hadn't, then we * would have returned above.) Thus, we know that it and its corresponding value are in * position `index`. */ V oldValue = uncheckedCastNullableTToT(values[index]);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 06 16:06:58 GMT 2023 - 36.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
bulkFuture.addListener( new Runnable() { @Override public void run() { /* * firstFuture just completed, but AggregateFuture hasn't yet had time to record the * exception in seenExceptions. When we complete secondFuture with the same exception, * we want for AggregateFuture to still detect that it's been previously seen.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/hash/HashStringBenchmark.java
} else if (userFriendly.matches("(?i)(?:Greek|Cyrillic|European|ISO.?8859)")) { // Mostly 2-byte UTF-8 sequences - "European" text return 0x800; } else if (userFriendly.matches("(?i)(?:Chinese|Han|Asian|BMP)")) { // Mostly 3-byte UTF-8 sequences - "Asian" text return Character.MIN_SUPPLEMENTARY_CODE_POINT; } else if (userFriendly.matches("(?i)(?:Cuneiform|rare|exotic|supplementary.*)")) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 5.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SpnegoContext.java
else { throw new SmbException("Invalid token"); } if ( spToken instanceof NegTokenTarg && this.mechContext.isEstablished() ) { // already established, but server hasn't completed yet NegTokenTarg targ = (NegTokenTarg) spToken; if ( targ.getResult() == NegTokenTarg.ACCEPT_INCOMPLETE && targ.getMechanismToken() == null && targ.getMechanismListMIC() != null ) {
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Mon Jan 04 04:18:31 GMT 2021 - 14.8K bytes - Viewed (0)