- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 382 for uatomic (0.05 seconds)
-
src/test/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGeneratorTest.java
assertEquals("Image Width", width, img.getWidth()); assertEquals("Image Height", height, img.getHeight()); } // Tests for atomic file operations (TOCTOU fix) @Test public void test_createDirectories_nestedPath() throws Exception { // Test that Files.createDirectories works correctly for nested paths
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 7.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/TestingCacheLoaders.java
import com.google.common.util.concurrent.ListenableFuture; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.HashMap; import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; import org.jspecify.annotations.NullUnmarked; import org.jspecify.annotations.Nullable; /** * Utility {@link CacheLoader} implementations intended for use in testing. * * @author mike nonemacherCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 13:13:59 GMT 2026 - 5.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/util/WebApiUtilTest.java
final int threadCount = 10; final java.util.concurrent.CountDownLatch latch = new java.util.concurrent.CountDownLatch(threadCount); final java.util.concurrent.atomic.AtomicInteger errorCount = new java.util.concurrent.atomic.AtomicInteger(0); for (int i = 0; i < threadCount; i++) { final int threadId = i; new Thread(() -> { try {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Jan 11 08:43:05 GMT 2026 - 17.4K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/SimplexTransferListener.java
import java.util.ArrayList; import java.util.List; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.Consumer; import org.eclipse.aether.transfer.AbstractTransferListener; import org.eclipse.aether.transfer.TransferCancelledException; import org.eclipse.aether.transfer.TransferEvent;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Feb 06 11:28:05 GMT 2025 - 8.7K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/SessionData.java
*/ <T> void set(@Nonnull Key<T> key, @Nullable T value); /** * Associates the specified session data with the given key if the key is currently mapped to the given value. This * method provides an atomic compare-and-update of some key's value. * * @param key the key under which to store the session data, must not be {@code null} * @param oldValue the expected data currently associated with the key, may be {@code null}Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Feb 28 23:31:09 GMT 2024 - 4.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java
import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.CountDownLatch; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import java.util.function.Consumer; import org.codelibs.core.lang.ThreadUtil; import org.codelibs.fess.crawler.Crawler;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 33.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
import com.google.common.annotations.J2ktIncompatible; import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicBoolean; import org.jspecify.annotations.Nullable; /** * Utilities necessary for working with libraries that supply plain {@link Future} instances. NoteCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 7.5K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java
import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.junit.jupiter.api.Test; /** * Security-focused test cases for BufferCache to verify buffer overflow protection. */ public class BufferCacheSecurityTest { /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 9.6K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java
import java.util.Collections; import java.util.HashMap; import java.util.HashSet; import java.util.Map; import java.util.Random; import java.util.Set; import java.util.concurrent.atomic.AtomicInteger; import org.codelibs.fess.suggest.Suggester; import org.codelibs.fess.suggest.settings.SuggestSettings; import org.codelibs.opensearch.runner.OpenSearchRunner; import org.junit.AfterClass;
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Nov 23 13:04:17 GMT 2025 - 8.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java
double z = a.addAndGet(y); assertBitEquals(x + y, z); assertBitEquals(x + y, a.get()); } } } /** a deserialized serialized atomic holds same value */ public void testSerialization() throws Exception { AtomicDouble a = new AtomicDouble(); AtomicDouble b = serialClone(a); assertThat(b).isNotSameInstanceAs(a); a.set(-22.0);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 7.3K bytes - Click Count (0)