Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 75 of 75 for CountDownLatch (0.07 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        }
      }
    
      private static final class PollingThread extends Thread {
        private final AbstractFuture<?> future;
        private final CountDownLatch completedIteration = new CountDownLatch(10);
    
        private PollingThread(AbstractFuture<?> future) {
          this.future = future;
        }
    
        @Override
        public void run() {
          while (true) {
            try {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        }
      }
    
      private static final class PollingThread extends Thread {
        private final AbstractFuture<?> future;
        private final CountDownLatch completedIteration = new CountDownLatch(10);
    
        private PollingThread(AbstractFuture<?> future) {
          this.future = future;
        }
    
        @Override
        public void run() {
          while (true) {
            try {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

    import java.net.UnknownHostException
    import java.net.UnknownServiceException
    import java.time.Duration
    import java.util.Arrays
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.Executors
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicBoolean
    import java.util.concurrent.atomic.AtomicInteger
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 147.4K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

    import java.net.InetAddress
    import java.net.InetSocketAddress
    import java.net.Proxy
    import java.net.UnknownHostException
    import java.time.Duration
    import java.util.Arrays
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.SocketEffect.CloseSocket
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 70.5K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

    import assertk.assertions.isLessThan
    import assertk.assertions.isNull
    import assertk.assertions.isTrue
    import java.io.EOFException
    import java.io.IOException
    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
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
Back to Top