Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 382 for uatomic (0.05 seconds)

  1. 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)
  2. 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 nonemacher
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 13:13:59 GMT 2026
    - 5.1K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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. Note
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  8. 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)
  9. 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)
  10. 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)
Back to Top