Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 11 for GuardedBy (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

        final L listener;
        final Executor executor;
    
        @GuardedBy("this")
        final Queue<ListenerCallQueue.Event<L>> waitQueue = new ArrayDeque<>();
    
        @GuardedBy("this")
        final Queue<Object> labelQueue = new ArrayDeque<>();
    
        @GuardedBy("this")
        boolean isThreadScheduled;
    
        PerListenerQueue(L listener, Executor executor) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  2. android/guava-testlib/src/com/google/common/testing/TearDownStack.java

    import static com.google.common.base.Throwables.throwIfUnchecked;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.VisibleForTesting;
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.ArrayDeque;
    import java.util.ArrayList;
    import java.util.Deque;
    import java.util.List;
    import java.util.logging.Level;
    import java.util.logging.Logger;
    import org.jspecify.annotations.NullMarked;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 01 13:14:50 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  3. guava-testlib/src/com/google/common/testing/TearDownStack.java

    import static com.google.common.base.Throwables.throwIfUnchecked;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.VisibleForTesting;
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.ArrayDeque;
    import java.util.ArrayList;
    import java.util.Deque;
    import java.util.List;
    import java.util.logging.Level;
    import java.util.logging.Logger;
    import org.jspecify.annotations.NullMarked;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 01 13:14:50 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            }
            return toReturn;
          }
    
          @GuardedBy("lock")
          /*
           * The GuardedBy checker warns us that we're not holding cancellationDelegate.lock. But in
           * fact we are holding it because it is the same as this.lock, which we know we are holding,
           * thanks to @GuardedBy above. (cancellationDelegate.lock is initialized to this.lock in the
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  5. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

        final L listener;
        final Executor executor;
    
        @GuardedBy("this")
        final Queue<ListenerCallQueue.Event<L>> waitQueue = new ArrayDeque<>();
    
        @GuardedBy("this")
        final Queue<Object> labelQueue = new ArrayDeque<>();
    
        @GuardedBy("this")
        boolean isThreadScheduled;
    
        PerListenerQueue(L listener, Executor executor) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static org.junit.Assert.assertThrows;
    
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.lang.reflect.Method;
    import java.net.URLClassLoader;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.Executor;
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  7. guava/src/com/google/common/cache/LocalCache.java

         * tail of the queue on write.
         */
        @GuardedBy("this")
        final Queue<ReferenceEntry<K, V>> writeQueue;
    
        /**
         * A queue of elements currently in the map, ordered by access time. Elements are added to the
         * tail of the queue on access (note that writes count as accesses).
         */
        @GuardedBy("this")
        final Queue<ReferenceEntry<K, V>> accessQueue;
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 19:35:11 GMT 2025
    - 148.9K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

        final Monitor monitor = new Monitor();
    
        @GuardedBy("monitor")
        final SetMultimap<State, Service> servicesByState =
            MultimapBuilder.enumKeys(State.class).linkedHashSetValues().build();
    
        @GuardedBy("monitor")
        final Multiset<State> states = servicesByState.keys();
    
        @GuardedBy("monitor")
        final IdentityHashMap<Service, Stopwatch> startupTimers = new IdentityHashMap<>();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 33.2K bytes
    - Click Count (1)
  9. guava/src/com/google/common/util/concurrent/ServiceManager.java

        final Monitor monitor = new Monitor();
    
        @GuardedBy("monitor")
        final SetMultimap<State, Service> servicesByState =
            MultimapBuilder.enumKeys(State.class).linkedHashSetValues().build();
    
        @GuardedBy("monitor")
        final Multiset<State> states = servicesByState.keys();
    
        @GuardedBy("monitor")
        final IdentityHashMap<Service, Stopwatch> startupTimers = new IdentityHashMap<>();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/cache/LocalCacheTest.java

    import junit.framework.TestCase;
    import junit.framework.TestSuite;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * @author Charles Fry
     */
    @SuppressWarnings("GuardedBy") // TODO(b/35466881): Fix or suppress.
    @NullUnmarked
    public class LocalCacheTest extends TestCase {
      @AndroidIncompatible
      private static class TestStringCacheGenerator extends TestStringMapGenerator {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 12 00:25:21 GMT 2025
    - 117.5K bytes
    - Click Count (0)
Back to Top