Search Options

Results per page
Sort
Preferred Languages
Advance

Results 751 - 760 of 1,022 for concurrency (0.05 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/badword/AdminBadwordAction.java

    import java.nio.file.Files;
    import java.nio.file.Path;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.beans.util.BeanUtil;
    import org.codelibs.core.concurrent.CommonPoolUtil;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.annotation.Secured;
    import org.codelibs.fess.app.pager.BadWordPager;
    import org.codelibs.fess.app.service.BadWordService;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/auth/chain/AuthenticationChainTest.java

            assertEquals(user2, chain.deleteCalls.get(0));
            assertEquals("user3", chain.changePasswordCalls.get(0).getKey());
            assertEquals(user1, chain.loadCalls.get(0));
        }
    
        // Test concurrent operations simulation
        public void test_implementation_sequentialOperations() {
            TestAuthenticationChain chain = new TestAuthenticationChain();
            List<User> users = new ArrayList<>();
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  3. okhttp-tls/src/test/java/okhttp3/tls/HeldCertificateTest.kt

    import assertk.assertions.matches
    import java.math.BigInteger
    import java.security.KeyFactory
    import java.security.spec.PKCS8EncodedKeySpec
    import java.security.spec.X509EncodedKeySpec
    import java.util.concurrent.TimeUnit
    import okhttp3.testing.PlatformRule
    import okhttp3.tls.HeldCertificate.Companion.decode
    import okio.ByteString.Companion.decodeBase64
    import org.bouncycastle.asn1.x509.GeneralName
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 22.6K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

    import java.io.InterruptedIOException
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicInteger
    import kotlin.test.assertFailsWith
    import okhttp3.Headers
    import okhttp3.Headers.Companion.headersOf
    import okhttp3.TestUtil.headerEntries
    import okhttp3.TestUtil.repeat
    import okhttp3.internal.EMPTY_BYTE_ARRAY
    import okhttp3.internal.concurrent.Lockable
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/AbstractMultimap.java

    import static com.google.common.base.Preconditions.checkNotNull;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.WeakOuter;
    import java.util.AbstractCollection;
    import java.util.Collection;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.Map.Entry;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 6.4K bytes
    - Viewed (0)
  6. README.md

    - **SLF4J Logging**: Comprehensive logging throughout the codebase
    - **Resource Management**: AutoCloseable patterns for file handles and connections
    - **Thread Safety**: Components support concurrent access
    - **DFS Support**: Distributed File System resolution
    - **Streaming Operations**: Efficient directory listings and file operations
    - **Buffer Caching**: Optimized buffer management
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 09:24:52 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProjectManager.java

     *
     * The service maintains the mutable state of projects as they progress through
     * their build lifecycle, ensuring thread-safety and proper state management.
     * All implementations must be thread-safe as they may be accessed concurrently
     * during parallel builds.
     *
     * @since 4.0.0
     * @see org.apache.maven.api.services.ProjectBuilder
     * @see Project
     */
    @Experimental
    public interface ProjectManager extends Service {
        /**
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Thu Jan 30 23:29:13 UTC 2025
    - 12K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/AbstractCacheTest.java

    import com.google.common.cache.AbstractCache.StatsCounter;
    import com.google.common.collect.ImmutableList;
    import com.google.common.collect.ImmutableMap;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.atomic.AtomicReference;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Unit test for {@link AbstractCache}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/witness/WitnessRegistration.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.internal.witness;
    
    import java.net.InetAddress;
    import java.util.concurrent.atomic.AtomicLong;
    
    /**
     * Represents a witness service registration for SMB resource monitoring.
     * This class maintains registration state, heartbeat information, and
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Mon Aug 25 14:34:10 UTC 2025
    - 6.7K bytes
    - Viewed (0)
  10. guava/src/com/google/common/escape/Escaper.java

     * resulting XML document is parsed, the parser API will return this text as the original literal
     * string {@code "Foo<Bar>"}.
     *
     * <p>An {@code Escaper} instance is required to be stateless, and safe when used concurrently by
     * multiple threads.
     *
     * <p>Because, in general, escaping operates on the code points of a string and not on its
     * individual {@code char} values, it is not safe to assume that {@code escape(s)} is equivalent to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 15:45:16 UTC 2025
    - 4.7K bytes
    - Viewed (0)
Back to top