- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for GuardedBy (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)