Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 958 for concurrence (0.07 sec)

  1. mockwebserver-deprecated/api/mockwebserver.api

    	public fun clone ()Lokhttp3/mockwebserver/MockResponse;
    	public final fun getBody ()Lokio/Buffer;
    	public final fun getBodyDelay (Ljava/util/concurrent/TimeUnit;)J
    	public final fun getHeaders ()Lokhttp3/Headers;
    	public final fun getHeadersDelay (Ljava/util/concurrent/TimeUnit;)J
    	public final fun getHttp2ErrorCode ()I
    	public final fun getPushPromises ()Ljava/util/List;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 10.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

     */
    package okhttp3
    
    import java.util.ArrayDeque
    import java.util.Collections
    import java.util.Deque
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.ThreadPoolExecutor
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.locks.ReentrantLock
    import okhttp3.internal.assertNotHeld
    import okhttp3.internal.connection.Locks.withLock
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

      // http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/main/java/util/concurrent/
    
      /** The queued items */
      final E[] items;
      /** items index for next take, poll or remove */
      int takeIndex;
      /** items index for next put, offer, or add. */
      int putIndex;
      /** Number of items in the queue */
      private int count;
    
      /*
       * Concurrency control uses the classic two-condition algorithm
       * found in any textbook.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 19 19:24:36 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Futures.java

    import com.google.j2objc.annotations.RetainedLocalRef;
    import java.time.Duration;
    import java.util.Collection;
    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.RejectedExecutionException;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/collect/testing/google/ReflectionFreeAssertThrows.java

    import java.nio.charset.UnsupportedCharsetException;
    import java.util.ConcurrentModificationException;
    import java.util.NoSuchElementException;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeoutException;
    import junit.framework.AssertionFailedError;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 19:10:20 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. guava-testlib/test/com/google/common/testing/ReflectionFreeAssertThrows.java

    import java.nio.charset.UnsupportedCharsetException;
    import java.util.ConcurrentModificationException;
    import java.util.NoSuchElementException;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeoutException;
    import junit.framework.AssertionFailedError;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 22 13:49:09 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpDebugLogging.kt

     */
    package okhttp3
    
    import java.io.Closeable
    import java.util.concurrent.CopyOnWriteArraySet
    import java.util.logging.ConsoleHandler
    import java.util.logging.Handler
    import java.util.logging.Level
    import java.util.logging.LogRecord
    import java.util.logging.Logger
    import java.util.logging.SimpleFormatter
    import kotlin.reflect.KClass
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.http2.Http2
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  8. internal/event/targetlist.go

    	CurrentSendCalls int64 // CurrentSendCalls is the number of concurrent async Send calls to all targets
    	CurrentQueue     int   // Populated if target has a store.
    	TotalEvents      int64
    	FailedEvents     int64 // Number of failed events per target
    }
    
    // TargetList - holds list of targets indexed by target ID.
    type TargetList struct {
    	// The number of concurrent async Send calls to all targets
    	currentSendCalls  atomic.Int64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

    import static com.google.common.util.concurrent.FuturesGetCheckedInputs.OTHER_THROWABLE;
    import static com.google.common.util.concurrent.FuturesGetCheckedInputs.RUNTIME_EXCEPTION;
    import static com.google.common.util.concurrent.FuturesGetCheckedInputs.RUNTIME_EXCEPTION_FUTURE;
    import static com.google.common.util.concurrent.FuturesGetCheckedInputs.UNCHECKED_EXCEPTION;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

    import android.annotation.SuppressLint
    import java.util.concurrent.ThreadFactory
    import java.util.concurrent.TimeUnit
    import java.util.logging.Handler
    import java.util.logging.Level
    import java.util.logging.LogManager
    import java.util.logging.LogRecord
    import java.util.logging.Logger
    import kotlin.concurrent.withLock
    import okhttp3.internal.buildConnectionPool
    import okhttp3.internal.concurrent.TaskRunner
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
Back to top