- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Guard (0.02 sec)
-
guava/src/com/google/common/util/concurrent/Monitor.java
for (Guard guard = activeGuards; guard != null; guard = guard.next) { guard.condition.signalAll(); } } /** Records that the current thread is about to wait on the specified guard. */ @GuardedBy("lock") private void beginWaitingFor(Guard guard) { int waiters = guard.waiterCount++; if (waiters == 0) { // push guard onto activeGuards guard.next = activeGuards;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 27K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.3K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 22.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 Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
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(); } }; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 18.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/ThrowablesTest.java
@J2ktIncompatible @GwtIncompatible // lazyStackTraceIsLazy() public void testLazyStackTraceWorksInProd() { // TODO(b/64442212): Remove this guard once lazyStackTrace() works in Java 9+. Integer javaVersion = Ints.tryParse(JAVA_SPECIFICATION_VERSION.value()); if (javaVersion != null && javaVersion >= 9) { return; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 14.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/ThrowablesTest.java
@J2ktIncompatible @GwtIncompatible // lazyStackTraceIsLazy() public void testLazyStackTraceWorksInProd() { // TODO(b/64442212): Remove this guard once lazyStackTrace() works in Java 9+. Integer javaVersion = Ints.tryParse(JAVA_SPECIFICATION_VERSION.value()); if (javaVersion != null && javaVersion >= 9) { return; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 14.9K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Files.java
* * <p>Copying is not an atomic operation - in the case of an I/O error, power loss, process * termination, or other problems, {@code to} may not be a complete copy of {@code from}. If you * need to guard against those conditions, you should employ other file-level synchronization. * * <p><b>Warning:</b> If {@code to} represents an existing file, that file will be overwritten
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 32.9K bytes - Viewed (0)