- Sort Score
- Result 10 results
- Languages All
Results 2051 - 2060 of 2,360 for created (0.08 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
private static final ExecutorService executor = Executors.newFixedThreadPool(1); @Override protected void setUp() throws Exception { super.setUp(); service = SimpleTimeLimiter.create(executor); } public void testNewProxy_goodMethodWithEnoughTime() throws Exception { SampleImpl target = new SampleImpl(DELAY_MS); Sample proxy = service.newProxy(target, Sample.class, ENOUGH_MS, MILLISECONDS);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/reflect/MutableTypeToInstanceMapTest.java
// but here we have to do some serious fudging @Override @SuppressWarnings({"unchecked", "rawtypes"}) public Map<TypeToken, Object> create(Object... elements) { MutableTypeToInstanceMap<Object> map = new MutableTypeToInstanceMap<>(); for (Object object : elements) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 7.9K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/TearDownStackTest.java
new TearDown() { @Override public void tearDown() throws Exception { synchronized (result.lock) { assertEquals( "The test should have cleared the stack (say, by virtue of running runTearDown)", 0, result.stack.size()); } } }); return result; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 21 10:19:29 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/http/listener.go
return TCPOptions{ UserTimeout: t.UserTimeout, Interface: t.Interface, SendBufSize: t.SendBufSize, RecvBufSize: t.RecvBufSize, NoDelay: true, } } // newHTTPListener - creates new httpListener object which is interface compatible to net.Listener. // httpListener is capable to // * listen to multiple addresses // * controls incoming connections only doing HTTP protocol
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5.6K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/ReferenceEntry.java
* <li>Loading: loading is pending * </ul> * * <p>Invalid: * * <ul> * <li>Expired: time expired (key/value may still be set) * <li>Collected: key/value was partially collected, but not yet cleaned up * <li>Unset: marked as unset, awaiting cleanup or reuse * </ul> */ @GwtIncompatible @ElementTypesAreNonnullByDefault interface ReferenceEntry<K, V> { /** Returns the value reference from this entry. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 3.5K bytes - Viewed (0) -
compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java
} private void maybeWarnAboutCleanUp() { if (warnAboutCleanup) { System.out.println("[WARNING] TestFileManager from: " + callerInfo.getClassName() + " not cleaned up!"); } } public void markForDeletion(File toDelete) { filesToDelete.add(toDelete); warnAboutCleanup = true; } public synchronized File createTempDir() {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
public abstract class AbstractListenableFutureTest extends TestCase { protected CountDownLatch latch; protected ListenableFuture<Boolean> future; @Override protected void setUp() throws Exception { // Create a latch and a future that waits on the latch. latch = new CountDownLatch(1); future = createListenableFuture(Boolean.TRUE, null, latch); } @Override protected void tearDown() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
service.stopAsync().awaitTerminated(); assertEquals("TestService [TERMINATED]", service.toString()); } public void testTimeout() throws Exception { // Create a service whose executor will never run its commands Service service = new TestService() { @Override protected Executor executor() { return new Executor() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 7.5K bytes - Viewed (0) -
guava/src/com/google/common/collect/Platform.java
* for insertions. */ static <E extends @Nullable Object> Set<E> preservesInsertionOrderOnAddsSet() { return CompactHashSet.create(); } /** * Returns a new array of the given length with the same type as a reference array. * * @param reference any array of the desired type * @param length the length of the new array */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Aug 06 17:52:51 UTC 2024 - 5.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/MapInterfaceTest.java
/** * Creates a new, empty instance of the class under test. * * @return a new, empty map instance. * @throws UnsupportedOperationException if it's not possible to make an empty instance of the * class under test. */ protected abstract Map<K, V> makeEmptyMap() throws UnsupportedOperationException; /** * Creates a new, non-empty instance of the class under test. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 43.8K bytes - Viewed (0)