Search Options

Results per page
Sort
Preferred Languages
Advance

Results 411 - 420 of 1,082 for concurrent (0.07 sec)

  1. src/test/java/jcifs/internal/witness/MockWitnessService.java

    package jcifs.internal.witness;
    
    import java.io.IOException;
    import java.net.InetAddress;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.atomic.AtomicBoolean;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /**
     * Mock witness service for integration testing.
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 09:06:40 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ArrayListMultimap.java

     * implement {@link java.util.RandomAccess}.
     *
     * <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=
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 05 23:15:58 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  3. guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java

    import java.util.LinkedHashMap;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.NoSuchElementException;
    import java.util.Set;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ExecutionException;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * LocalCache emulation for GWT.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  4. okhttp/src/jvmMain/java9/module-info.java

      exports okhttp3;
      exports okhttp3.internal to okhttp3.logging, okhttp3.sse, okhttp3.java.net.cookiejar, okhttp3.dnsoverhttps, mockwebserver3, okhttp3.mockwebserver, okhttp3.coroutines, okhttp3.tls;
      exports okhttp3.internal.concurrent to mockwebserver3, okhttp3.mockwebserver;
      exports okhttp3.internal.connection to mockwebserver3, okhttp3.mockwebserver, okhttp3.logging;
      exports okhttp3.internal.http to okhttp3.logging, okhttp3.brotli, mockwebserver3;
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Sep 21 08:30:26 UTC 2025
    - 969 bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/WholeOperationTimeoutTest.kt

    import assertk.assertions.isTrue
    import java.io.IOException
    import java.io.InterruptedIOException
    import java.net.HttpURLConnection
    import java.time.Duration
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicReference
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.junit5.StartStop
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static java.lang.Math.max;
    import static java.lang.reflect.Modifier.isStatic;
    import static java.util.concurrent.TimeUnit.MICROSECONDS;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static java.lang.Math.max;
    import static java.lang.reflect.Modifier.isStatic;
    import static java.util.concurrent.TimeUnit.MICROSECONDS;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/net/protocol/storage/HandlerTest.java

    import java.io.IOException;
    import java.net.URL;
    import java.net.URLConnection;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.fess.crawler.container.StandardCrawlerContainer;
    import org.dbflute.utflute.core.PlainTestCase;
    
    /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  9. 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
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  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
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.2K bytes
    - Viewed (0)
Back to top