Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 491 - 500 of 1,025 for concurrency (0.06 seconds)

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

  1. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

    import assertk.assertions.isCloseTo
    import assertk.assertions.isFalse
    import assertk.assertions.isInstanceOf
    import assertk.assertions.matchesPredicate
    import java.util.Deque
    import java.util.concurrent.ConcurrentLinkedDeque
    import java.util.concurrent.TimeUnit
    import okhttp3.ConnectionEvent.NoNewExchanges
    import okhttp3.internal.connection.ConnectionListener
    import okhttp3.internal.connection.RealConnection
    import okio.IOException
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/cache/LongAddable.java

     * the License.
     */
    
    package com.google.common.cache;
    
    import com.google.common.annotations.GwtCompatible;
    
    /**
     * Abstract interface for objects that can concurrently add longs.
     *
     * @author Louis Wasserman
     */
    @GwtCompatible
    interface LongAddable {
      void increment();
    
      void add(long x);
    
      long sum();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 885 bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/cache/CacheBuilderGwtTest.java

    import java.util.HashSet;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.Map.Entry;
    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.junit.Before;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.junit.runners.JUnit4;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 15K bytes
    - Click Count (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/testers/ConcurrentMapPutIfAbsentTester.java

    import com.google.errorprone.annotations.CanIgnoreReturnValue;
    import java.util.Map.Entry;
    import java.util.concurrent.ConcurrentMap;
    import org.jspecify.annotations.NullMarked;
    import org.junit.Ignore;
    
    /**
     * A generic JUnit test which tests {@code putIfAbsent} 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
    - 4.9K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/suggest/SuggesterBuilder.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.suggest;
    
    import java.io.IOException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    import org.codelibs.fess.suggest.analysis.SuggestAnalyzer;
    import org.codelibs.fess.suggest.converter.ReadingConverter;
    import org.codelibs.fess.suggest.exception.SuggesterException;
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Mon Nov 24 03:40:05 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.7K bytes
    - Click Count (0)
  7. okhttp/src/jvmMain/java9/module-info.java

      exports okhttp3.internal to okhttp3.logging, okhttp3.sse, okhttp3.java.net.cookiejar, okhttp3.dnsoverhttps, mockwebserver3, okhttp3.mockwebserver, mockwebserver3.junit5, 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;
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 992 bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/Tags.kt

     */
    package okhttp3.internal
    
    import java.util.concurrent.atomic.AtomicReference
    import kotlin.reflect.KClass
    
    /**
     * An immutable collection of key-value pairs implemented as a singly-linked list.
     *
     * Build up a collection by starting with [EmptyTags] and repeatedly calling [plus]. Each such call
     * returns a new instance.
     *
     * This collection is optimized for safe concurrent access over a very small number of elements.
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 3.9K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/fess/thumbnail/ThumbnailGeneratorTest.java

            // Test thread safety with concurrent operations
            final int threadCount = 10;
            Thread[] threads = new Thread[threadCount];
            final boolean[] results = new boolean[threadCount];
    
            for (int i = 0; i < threadCount; i++) {
                final int index = i;
                threads[i] = new Thread(() -> {
                    String thumbnailId = "concurrent-" + index;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 11.7K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

     */
    package org.codelibs.fess.helper;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.util.List;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    import java.util.function.Consumer;
    
    import org.apache.commons.io.IOUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 06:54:47 GMT 2025
    - 10.9K bytes
    - Click Count (0)
Back to Top