- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,648 for findall (0.23 sec)
-
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
// http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/main/java/util/concurrent/ private static final long serialVersionUID = 5595510919245408276L; final PriorityQueue<E> q; final Monitor monitor = new Monitor(true); private final Monitor.Guard notEmpty = new Monitor.Guard(monitor) { @Override public boolean isSatisfied() { return !q.isEmpty();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 19.5K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/SipHashFunction.java
*/ @Immutable @ElementTypesAreNonnullByDefault final class SipHashFunction extends AbstractHashFunction implements Serializable { static final HashFunction SIP_HASH_24 = new SipHashFunction(2, 4, 0x0706050403020100L, 0x0f0e0d0c0b0a0908L); // The number of compression rounds. private final int c; // The number of finalization rounds. private final int d; // Two 64-bit keys (represent a single 128-bit key).
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 20 18:43:59 GMT 2021 - 5.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/SourceSinkFactories.java
@Override public void tearDown() throws IOException { factory.tearDown(); } }; } public static ByteSourceFactory asSlicedByteSourceFactory( final ByteSourceFactory factory, final long off, final long len) { checkNotNull(factory); return new ByteSourceFactory() { @Override public ByteSource createSource(byte[] bytes) throws IOException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 12.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CloserTest.java
private final List<Suppression> suppressions = Lists.newArrayList(); @Override public void suppress(Closeable closeable, Throwable thrown, Throwable suppressed) { suppressions.add(new Suppression(closeable, thrown, suppressed)); } } /** Record of a call to suppress. */ private static class Suppression { private final Closeable closeable;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Mar 06 15:15:46 GMT 2024 - 13.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} public void testDirectExecutorServiceServiceTermination() throws Exception { final ExecutorService executor = newDirectExecutorService(); final CyclicBarrier barrier = new CyclicBarrier(2); final AtomicReference<Throwable> throwableFromOtherThread = new AtomicReference<>(null); final Runnable doNothingRunnable = new Runnable() { @Override public void run() {}
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharSinkTester.java
TestSuite stringSuite = new TestSuite(name + " [" + desc + "]"); for (final Method method : testMethods) { stringSuite.addTest(new CharSinkTester(factory, string, name, desc, method)); } return stringSuite; } private final ImmutableList<String> lines; private final ImmutableList<String> expectedLines; private CharSink sink; public CharSinkTester(
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/IoTestCase.java
*/ public abstract class IoTestCase extends TestCase { private static final Logger logger = Logger.getLogger(IoTestCase.class.getName()); static final String I18N = "\u00CE\u00F1\u0163\u00E9\u0072\u00F1\u00E5\u0163\u00EE\u00F6" + "\u00F1\u00E5\u013C\u00EE\u017E\u00E5\u0163\u00EE\u00F6\u00F1"; static final String ASCII = " !\"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ"
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 5.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
try { runTestMethod(NO_UNSAFE); } finally { Thread.currentThread().setContextClassLoader(oldClassLoader); } Thread.currentThread().setContextClassLoader(NO_ATOMIC_REFERENCE_FIELD_UPDATER); try { runTestMethod(NO_ATOMIC_REFERENCE_FIELD_UPDATER); // TODO(lukes): assert that the logs are full of errors } finally { Thread.currentThread().setContextClassLoader(oldClassLoader);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 6.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java
* * @author Kevin Bourrillion * @author Chris Povirk */ final class InterruptionUtil { private static final Logger logger = Logger.getLogger(InterruptionUtil.class.getName()); /** Runnable which will interrupt the target thread repeatedly when run. */ private static final class Interruptenator implements Runnable { private final long everyMillis; private final Thread interruptee; private volatile boolean shouldStop = false;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4.4K bytes - Viewed (0) -
android/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 May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.4K bytes - Viewed (0)