Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 451 - 460 of 1,040 for concurrency (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapReplaceTester.java

    import com.google.common.collect.testing.features.CollectionSize;
    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)} 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
    - 3.9K bytes
    - Click Count (0)
  2. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

    import static org.junit.Assert.assertThrows;
    
    import com.google.common.util.concurrent.SettableFuture;
    import java.lang.ref.Reference;
    import java.lang.ref.WeakReference;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.util.WeakHashMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.atomic.AtomicBoolean;
    import junit.framework.TestCase;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:11:48 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

    import okhttp3.FakeRoutePlanner
    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.TestUtil.awaitGarbageCollection
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.concurrent.TaskRunner.RealBackend
    import okhttp3.internal.concurrent.withLock
    import okhttp3.internal.http2.MockHttp2Peer
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Test
    
    class ConnectionPoolTest {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

    import java.io.Closeable
    import java.io.IOException
    import java.net.InetSocketAddress
    import java.net.ServerSocket
    import java.net.Socket
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.Executors
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.logging.Logger
    import okhttp3.TestUtil.threadFactory
    import okhttp3.internal.closeQuietly
    import okio.Buffer
    import okio.BufferedSource
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  5. 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)
  6. docs/bucket/replication/DESIGN.md

    question - i.e with `mc stat --version-id dm-version-id`
    
    It must be noted that if active-active replication is set up with delete marker replication, there is potential for duplicate delete markers to be created if both source and target concurrently set a Delete Marker or if one/both of the clusters went down at tandem before the replication event was synced.This is an unavoidable side-effect in active-active replication caused by allowing delete markers set on a object version with `REPLICA`...
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    import java.util.logging.LogRecord;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 91K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/collect/ForwardingConcurrentMapTest.java

     * limitations under the License.
     */
    
    package com.google.common.collect;
    
    import static com.google.common.truth.Truth.assertThat;
    
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link ForwardingConcurrentMap}.
     *
     * @author Jared Levy
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Oct 28 16:03:47 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  9. src/main/java/jcifs/SmbWatchHandle.java

     * License along with this library; if not, write to the Free Software
     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs;
    
    import java.util.List;
    import java.util.concurrent.Callable;
    
    /**
     * Handle for receiving change notifications from an SMB server
     *
     *
     * @author mbechler
     *
     */
    public interface SmbWatchHandle extends AutoCloseable, Callable<List<FileNotifyInformation>> {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainFinallyHookTest.java

     */
    package org.codelibs.fess.mylasta.direction.sponsor;
    
    import java.lang.reflect.Field;
    import java.lang.reflect.Method;
    import java.net.URL;
    import java.net.URLClassLoader;
    import java.util.concurrent.atomic.AtomicBoolean;
    
    import org.codelibs.fess.unit.UnitFessTestCase;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.TestInfo;
    import org.lastaflute.core.direction.FwAssistantDirector;
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 8.7K bytes
    - Click Count (0)
Back to Top