- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 544 for pcall (0.15 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
new Thread() { @Override public void run() { notifyStarted(); // We need to wait for the main thread to leave the ServiceManager.startAsync call // to // ensure that the thread running the failure callbacks is not the main thread. Uninterruptibles.awaitUninterruptibly(afterStarted);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
boolean run = false; @Override public void run() { run = true; } } private static class TestCallable implements Callable<String> { @Override public String call() { return "foo"; } } /** Simple same thread listening executor service that doesn't handle shutdown. */ private static class TestListeningExecutorService extends AbstractListeningExecutorService {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 3.2K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheLoader.java
/** * Computes or retrieves a replacement value corresponding to an already-cached {@code key}. This * method is called when an existing cache entry is refreshed by {@link * CacheBuilder#refreshAfterWrite}, or through a call to {@link LoadingCache#refresh}. * * <p>This implementation synchronously delegates to {@link #load}. It is recommended that it be * overridden with an asynchronous implementation when using {@link
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon Dec 19 20:20:14 GMT 2022 - 9.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
import org.checkerframework.checker.nullness.qual.Nullable; /** * Utilities for treating interruptible operations as uninterruptible. In all cases, if a thread is * interrupted during such a call, the call continues to block until the result is available or the * timeout elapses, and only then re-interrupts the thread. * * @author Anthony Zana * @since 10.0 */ @GwtCompatible(emulated = true)
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 14.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java
public static FinalizableReferenceQueue frq = new FinalizableReferenceQueue(); public static final Semaphore finalized = new Semaphore(0); @Override public WeakReference<Object> call() { WeakReference<Object> wr = new FinalizableWeakReference<Object>(new Integer(23), frq) { @Override public void finalizeReferent() { finalized.release();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 13.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java
Method method = getTestSubscriberMethod("recordingMethod"); Subscriber subscriber = Subscriber.create(bus, this, method); subscriber.invokeSubscriberMethod(FIXTURE_ARGUMENT); assertTrue("Subscriber must call provided method", methodCalled); assertTrue( "Subscriber argument must be exactly the provided object.", methodArgument == FIXTURE_ARGUMENT); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/reflect/InvokableTest.java
new EqualsTester() .addEqualityGroup(parameters.get(0)) .addEqualityGroup(parameters.get(1)) .testEquals(); } public void testConstructor_call() throws Exception { Invokable<?, Prepender> delegate = Prepender.constructor(String.class, int.class); Prepender prepender = delegate.invoke(null, "a", 1); assertEquals("a", prepender.prefix);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 30.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/AbstractIteratorTest.java
*/ @GwtCompatible(emulated = true) public class AbstractIteratorTest extends TestCase { public void testDefaultBehaviorOfNextAndHasNext() { // This sample AbstractIterator returns 0 on the first call, 1 on the // second, then signals that it's reached the end of the data Iterator<Integer> iter = new AbstractIterator<Integer>() { private int rep; @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu May 04 09:41:29 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/AbstractIteratorTest.java
*/ @GwtCompatible(emulated = true) public class AbstractIteratorTest extends TestCase { public void testDefaultBehaviorOfNextAndHasNext() { // This sample AbstractIterator returns 0 on the first call, 1 on the // second, then signals that it's reached the end of the data Iterator<Integer> iter = new AbstractIterator<Integer>() { private int rep; @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu May 04 09:41:29 GMT 2023 - 6.1K bytes - Viewed (0) -
guava/src/com/google/common/base/Functions.java
public int hashCode() { return Objects.hashCode(map, defaultValue); } @Override public String toString() { // TODO(cpovirk): maybe remove "defaultValue=" to make this look like the method call does return "Functions.forMap(" + map + ", defaultValue=" + defaultValue + ")"; } private static final long serialVersionUID = 0; } /**
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 14.1K bytes - Viewed (0)