- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 131 for AtomicInteger (0.11 seconds)
-
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
assertThat(stats.loadExceptionCount()).isEqualTo(1); assertThat(stats.hitCount()).isEqualTo(0); } public void testReloadAfterFailure() throws ExecutionException { AtomicInteger count = new AtomicInteger(); Exception e = new IllegalStateException("exception to trigger failure on first load()"); CacheLoader<Integer, String> failOnceFunction = new CacheLoader<Integer, String>() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 91K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java
*/ protected String sessionId; /** * Atomic counter for tracking active crawler threads without lock contention. */ protected final AtomicInteger activeThreadCount = new AtomicInteger(0); /** * Atomic counter for tracking the number of accesses made. */ protected AtomicLong accessCount = new AtomicLong(0); /** * Current status of the crawler.Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Dec 31 09:07:38 GMT 2025 - 9K bytes - Click Count (0) -
guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java
private final Class<T> interfaceType; private final Method method; private final @Nullable Object[] passedArgs; private final @Nullable Object returnValue; private final AtomicInteger called = new AtomicInteger(); InteractionTester(Class<T> interfaceType, Method method) { this.interfaceType = interfaceType; this.method = method; this.passedArgs = getParameterValues(method);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 9.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/util/SearchEngineUtilTest.java
// Note: In a real test environment, this would require proper SearchEngineClient setup // For now, we test that the method signature is correct and can be called AtomicInteger callbackCount = new AtomicInteger(0); try { // This will likely fail due to missing SearchEngineClient setup, // but we can verify the method signature and basic functionalityCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 13.8K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/CrawlingConfigHelperTest.java
assertEquals("name", fieldSortBuilderList.get(1).getFieldName()); } @Test public void test_getExcludedUrlList() { final AtomicInteger errorCount = new AtomicInteger(0); final DynamicProperties systemProperties = ComponentUtil.getSystemProperties(); final FailureUrlCB cb = new FailureUrlCB(); ComponentUtil.register(new FailureUrlBhv() {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 35.3K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java
import java.util.Comparator; import java.util.List; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.LongAdder; import java.util.function.Predicate; import java.util.stream.Stream; import org.apache.maven.api.Constants; import org.apache.maven.api.ProtoSession;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jul 18 17:30:19 GMT 2025 - 11.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java
private volatile boolean isComplete; private volatile boolean hasChanges; private DirectoryCacheScope scope; private long maxAge; private final AtomicInteger inconsistencyCount = new AtomicInteger(0); /** * Create a new directory cache entry * * @param path the directory path * @param key the lease key * @param scope the cache scope */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 11.4K bytes - Click Count (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java
// Poll concurrently final CountDownLatch startLatch = new CountDownLatch(1); final CountDownLatch doneLatch = new CountDownLatch(numThreads); final AtomicInteger totalPolled = new AtomicInteger(0); final List<String> allUrls = new ArrayList<>(); for (int i = 0; i < numThreads; i++) { new Thread(() -> { try {Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Jan 14 23:48:16 GMT 2026 - 14.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
*/ // We use an anonymous class to be sure that we generate two methods (bridge and original). @SuppressWarnings("AnonymousToLambda") public void testRegistrationWithBridgeMethod() { AtomicInteger calls = new AtomicInteger(); bus.register( new Callback<String>() { @Subscribe @Override public void call(String s) { calls.incrementAndGet(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 11.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
*/ // We use an anonymous class to be sure that we generate two methods (bridge and original). @SuppressWarnings("AnonymousToLambda") public void testRegistrationWithBridgeMethod() { AtomicInteger calls = new AtomicInteger(); bus.register( new Callback<String>() { @Subscribe @Override public void call(String s) { calls.incrementAndGet(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 11.6K bytes - Click Count (0)