- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for SynchronizedSubscriber (0.2 sec)
-
android/guava/src/com/google/common/eventbus/Subscriber.java
/** * Subscriber that synchronizes invocations of a method to ensure that only one thread may enter * the method at a time. */ @VisibleForTesting static final class SynchronizedSubscriber extends Subscriber { private SynchronizedSubscriber(EventBus bus, Object target, Method method) { super(bus, target, method); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 4.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java
assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class); // a thread-safe method should not create a synchronized subscriber Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class); } public void testInvokeSubscriberMethod_basicMethodCall() throws Throwable {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/SubscriberTest.java
assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class); // a thread-safe method should not create a synchronized subscriber Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class); } public void testInvokeSubscriberMethod_basicMethodCall() throws Throwable {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.8K bytes - Viewed (0)