- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 77 for Treacy (0.17 sec)
-
guava/src/com/google/common/collect/AbstractIterator.java
private State state = State.NOT_READY; /** Constructor for use by subclasses. */ protected AbstractIterator() {} private enum State { /** We have computed the next element and haven't returned it yet. */ READY, /** We haven't yet computed or have already returned the element. */ NOT_READY, /** We have reached the end of the data and are finished. */
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Mar 18 02:04:10 GMT 2022 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
// even check the guard. I don't think we care too much about this use case but it could lead // to a confusing error message. throw new TimeoutException("Timed out waiting for " + this + " to reach the RUNNING state."); } } @Override public final void awaitTerminated() { monitor.enterWhenUninterruptibly(isStopped); try { checkCurrentState(TERMINATED); } finally {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 20.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/LazyLogger.java
private volatile @Nullable Logger logger; LazyLogger(Class<?> ownerOfLogger) { this.loggerName = ownerOfLogger.getName(); } Logger get() { /* * We use double-checked locking. We could the try racy single-check idiom, but that would * depend on Logger not contain mutable state. * * We could use Suppliers.memoizingSupplier here, but I micro-optimized to this implementation
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LongAdder.java
/** * Resets variables maintaining the sum to zero. This method may be a useful alternative to * creating a new adder, but is only effective if there are no concurrent updates. Because this * method is intrinsically racy, it should only be used when it is known that no threads are * concurrently updating. */ public void reset() { internalReset(0L); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jun 15 18:00:07 GMT 2021 - 5.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
assertThrows( TimeoutException.class, () -> service.startAsync().awaitRunning(1, MILLISECONDS)); assertThat(e) .hasMessageThat() .isEqualTo("Timed out waiting for Foo [STARTING] to reach the RUNNING state."); } private class TestService extends AbstractScheduledService { CyclicBarrier runFirstBarrier = new CyclicBarrier(2); CyclicBarrier runSecondBarrier = new CyclicBarrier(2);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* cleared, we know that we're not executing inline any more * </ul> * * All the states where thread != currentThread are identical for our purposes, and so even * though it's racy, we don't care which of those values we get, so no need to synchronize. */ @CheckForNull @LazyInit Thread thread; /** Only used by the thread associated with this object */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
// way in such a visibility issue would surface is most likely as a failure of cancel() to // propagate to the input. Cancellation propagation is fundamentally racy so this is fine. // // Future versions of the JMM may revise safe construction semantics in such a way that we can // safely publish these objects and we won't need this whole discussion.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
} /** * Waits for the all the services to reach a terminal state. After this method returns all * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain * Service.State#FAILED failed}. */ public void awaitStopped() { state.awaitStopped(); } /** * Waits for the all the services to reach a terminal state for no more than the given time. After
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/EventBus.java
* does it offer a way to batch multiple events from a single producer together. * <li>It doesn't support backpressure and other features needed for resilience. * <li>It doesn't provide much control of threading. * <li>It doesn't offer much monitoring. * <li>It doesn't propagate exceptions, so apps don't have a way to react to them.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Aug 25 16:37:57 GMT 2021 - 12.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/DerivedCollectionGenerators.java
// should never reach here! throw new UnsupportedOperationException(); } @Override public Entry<K, V> belowSamplesGreater() { // should never reach here! throw new UnsupportedOperationException(); } @Override public Entry<K, V> aboveSamplesLesser() { // should never reach here! throw new UnsupportedOperationException();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 18.2K bytes - Viewed (0)