- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for Guard (0.03 sec)
-
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
// (b) Waiting for the single guard to become satisfied. // (c) Occupying the monitor and awaiting the tearDownLatch. // // Except for (c), every thread should occupy the monitor very briefly, and every thread leaves // the monitor with the guard satisfied. Therefore as soon as tearDownLatch is triggered, we // should be able to enter the monitor, and then we set the guard to satisfied for the benefit
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 23 14:18:12 UTC 2024 - 27.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
// (b) Waiting for the single guard to become satisfied. // (c) Occupying the monitor and awaiting the tearDownLatch. // // Except for (c), every thread should occupy the monitor very briefly, and every thread leaves // the monitor with the guard satisfied. Therefore as soon as tearDownLatch is triggered, we // should be able to enter the monitor, and then we set the guard to satisfied for the benefit
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 27.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
private final Guard isStartable = new IsStartableGuard(); @WeakOuter private final class IsStartableGuard extends Guard { IsStartableGuard() { super(AbstractService.this.monitor); } @Override public boolean isSatisfied() { return state() == NEW; } } private final Guard isStoppable = new IsStoppableGuard(); @WeakOuter
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
private final Guard isStartable = new IsStartableGuard(); @WeakOuter private final class IsStartableGuard extends Guard { IsStartableGuard() { super(AbstractService.this.monitor); } @Override public boolean isSatisfied() { return state() == NEW; } } private final Guard isStoppable = new IsStoppableGuard(); @WeakOuter
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2); assertThrows(IllegalMonitorStateException.class, () -> monitor1.getWaitQueueLength(guard)); } public void testHasWaitersWithWrongMonitorThrowsIMSE() { Monitor monitor1 = new Monitor(); Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 4.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2); assertThrows(IllegalMonitorStateException.class, () -> monitor1.getWaitQueueLength(guard)); } public void testHasWaitersWithWrongMonitorThrowsIMSE() { Monitor monitor1 = new Monitor(); Monitor monitor2 = new Monitor(); FlagGuard guard = new FlagGuard(monitor2);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 4.9K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* found in any textbook. */ /** Monitor guarding all access */ final Monitor monitor; /** Guard for waiting takes */ private final Monitor.Guard notEmpty; /** Guard for waiting puts */ private final Monitor.Guard notFull; // Internal helper methods /** Circularly increment i. */ final int inc(int i) { return (++i == items.length) ? 0 : i; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/platform/PlatformTest.kt
import org.junit.jupiter.api.extension.RegisterExtension class PlatformTest { @RegisterExtension var platform = PlatformRule() @Test fun alwaysBuilds() { Platform() } /** Guard against the default value changing by accident. */ @Test fun defaultPrefix() { assertThat(Platform().getPrefix()).isEqualTo("OkHttp") } @Test fun testToStringIsClassname() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Jan 04 05:32:07 UTC 2024 - 1.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* which it is guaranteed that it can never become healthy. */ final Monitor.Guard awaitHealthGuard = new AwaitHealthGuard(); @WeakOuter final class AwaitHealthGuard extends Monitor.Guard { AwaitHealthGuard() { super(ServiceManagerState.this.monitor); } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
* which it is guaranteed that it can never become healthy. */ final Monitor.Guard awaitHealthGuard = new AwaitHealthGuard(); @WeakOuter final class AwaitHealthGuard extends Monitor.Guard { AwaitHealthGuard() { super(ServiceManagerState.this.monitor); } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.2K bytes - Viewed (0)