Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 27 for GuardedBy (0.13 sec)

  1. android/guava-tests/benchmark/com/google/common/cache/ChainBenchmark.java

      int length;
    
      private Segment<Object, Object> segment;
      private ReferenceEntry<Object, Object> head;
      private @Nullable ReferenceEntry<Object, Object> chain;
    
      @SuppressWarnings("GuardedBy")
      @BeforeExperiment
      void setUp() {
        LocalCache<Object, Object> cache =
            new LocalCache<>(CacheBuilder.newBuilder().concurrencyLevel(1), null);
        segment = cache.segments[0];
        chain = null;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 17 15:19:38 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

        static final Logger log = Logger.getLogger(NewExecutionListQueue.class.getName());
    
        @GuardedBy("this")
        private @Nullable RunnableExecutorPair head;
    
        @GuardedBy("this")
        private @Nullable RunnableExecutorPair tail;
    
        @GuardedBy("this")
        private boolean executed;
    
        public void add(Runnable runnable, Executor executor) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. 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<>();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  4. 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<>();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

      /**
       * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
       * RunnableExecutorPair#next} field.
       */
      @GuardedBy("this")
      @CheckForNull
      private RunnableExecutorPair runnables;
    
      @GuardedBy("this")
      private boolean executed;
    
      /** Creates a new, empty {@link ExecutionList}. */
      public ExecutionList() {}
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.Map;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import javax.annotation.concurrent.GuardedBy;
    import junit.framework.TestCase;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.Map;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import javax.annotation.concurrent.GuardedBy;
    import junit.framework.TestCase;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  8. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  9. guava-tests/benchmark/com/google/common/cache/SegmentBenchmark.java

        for (int i = 0; i < segment.threshold; i++) {
          cache.put(new Object(), new Object());
        }
        checkState(segment.table.length() == capacity);
      }
    
      @SuppressWarnings("GuardedBy")
      @Benchmark
      int time(int reps) {
        int dummy = 0;
        AtomicReferenceArray<ReferenceEntry<Object, Object>> oldTable = segment.table;
        for (int i = 0; i < reps; i++) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 23 16:59:39 UTC 2019
    - 2.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AbstractService.java

    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.ForOverride;
    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import com.google.j2objc.annotations.WeakOuter;
    import java.time.Duration;
    import java.util.concurrent.Executor;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
Back to top