Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 81 - 90 of 1,335 for concurrent (0.09 seconds)

  1. src/test/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticatorTest.java

     */
    package org.codelibs.fess.sso.entraid;
    
    import java.lang.reflect.Method;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicReference;
    
    import org.codelibs.core.misc.Pair;
    import org.codelibs.fess.app.web.base.login.EntraIdCredential.EntraIdUser;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 19.3K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/fess/script/ScriptEngineFactoryTest.java

            assertNotNull(retrieved);
            assertEquals(engine, retrieved);
        }
    
        // Test concurrent-like scenario (sequential but simulating concurrent behavior)
        @Test
        public void test_add_multipleSameNameSequential() {
            TestScriptEngine engine1 = new TestScriptEngine("v1");
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.8K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt

    import okhttp3.internal.concurrent.assertLockHeld
    import okhttp3.internal.concurrent.assertLockNotHeld
    import okhttp3.internal.concurrent.withLock
    import okhttp3.internal.http.ExchangeCodec
    import okhttp3.internal.http.RealInterceptorChain
    import okhttp3.internal.http1.Http1ExchangeCodec
    import okhttp3.internal.http2.ConnectionShutdownException
    import okhttp3.internal.http2.ErrorCode
    import okhttp3.internal.http2.FlowControlListener
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 14.6K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/user/EditForm.java

         */
        @Required
        @Size(max = 1000)
        public String id;
    
        /**
         * The version number of the user for optimistic locking.
         * This field is required to prevent concurrent modification conflicts
         * by ensuring the user hasn't been modified by another process.
         */
        @Required
        @ValidateTypeFailure
        public Integer versionNo;
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/LinkedListMultimap.java

     *
     * <p>Keys and values may be null. All optional multimap methods are supported, and all returned
     * views are modifiable.
     *
     * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent
     * read operations will work correctly. To allow concurrent update operations, wrap your multimap
     * with a call to {@link Multimaps#synchronizedListMultimap}.
     *
     * <p>See the Guava User Guide article on <a href=
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 27K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/accesstoken/EditForm.java

         * Stored as a long value representing milliseconds since epoch.
         * Used for audit trail and concurrency control.
         */
        @ValidateTypeFailure
        public Long updatedTime;
    
        /**
         * The version number of the access token for optimistic locking.
         * This field is required to prevent concurrent modification conflicts
         * by ensuring the token hasn't been modified by another process.
         */
        @Required
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  7. guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapReplaceEntryTester.java

    import com.google.common.collect.testing.features.MapFeature;
    import java.util.concurrent.ConcurrentMap;
    import org.jspecify.annotations.NullMarked;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code replace(K, V, V)} operations on a concurrent map. Can't
     * be invoked directly; please see {@link
     * com.google.common.collect.testing.ConcurrentMapTestSuiteBuilder}.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 14:50:24 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/duplicatehost/EditForm.java

         * Stored as a long value representing milliseconds since epoch.
         * Used for audit trail and concurrency control.
         */
        @ValidateTypeFailure
        public Long updatedTime;
    
        /**
         * The version number of the duplicate host configuration for optimistic locking.
         * This field is required to prevent concurrent modification conflicts
         * by ensuring the configuration hasn't been modified by another process.
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    import java.util.Objects;
    import java.util.Set;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.ThreadPoolExecutor;
    import java.util.concurrent.TimeUnit;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 29.7K bytes
    - Click Count (3)
  10. src/main/java/org/codelibs/fess/app/web/admin/badword/EditForm.java

         * Stored as a long value representing milliseconds since epoch.
         * Used for audit trail and concurrency control.
         */
        @ValidateTypeFailure
        public Long updatedTime;
    
        /**
         * The version number of the bad word entry for optimistic locking.
         * This field is required to prevent concurrent modification conflicts
         * by ensuring the entry hasn't been modified by another process.
         */
        @Required
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 2.2K bytes
    - Click Count (0)
Back to Top