Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 25 for GuardedBy (0.06 sec)

  1. 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;
    
        void add(Runnable runnable, Executor executor) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Monitor.java

       *
       * @since 10.0
       */
      public abstract static class Guard {
    
        @Weak final Monitor monitor;
        final Condition condition;
    
        @GuardedBy("monitor.lock")
        int waiterCount = 0;
    
        /** The next active guard */
        @GuardedBy("monitor.lock")
        @Nullable Guard next;
    
        protected Guard(Monitor monitor) {
          this.monitor = checkNotNull(monitor, "monitor");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  3. 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")
      private @Nullable RunnableExecutorPair runnables;
    
      @GuardedBy("this")
      private boolean executed;
    
      /** Creates a new, empty {@link ExecutionList}. */
      public ExecutionList() {}
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. 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;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  5. 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;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  6. 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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  7. 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")
      private @Nullable RunnableExecutorPair runnables;
    
      @GuardedBy("this")
      private boolean executed;
    
      /** Creates a new, empty {@link ExecutionList}. */
      public ExecutionList() {}
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/AbstractService.java

    import com.google.common.util.concurrent.Service.State;
    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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
Back to top