Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 79 of 79 for countdown (0.2 sec)

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

        ScheduledThreadPoolExecutor delegate =
            new ScheduledThreadPoolExecutor(1) {
              @Override
              protected void afterExecute(Runnable r, Throwable t) {
                completed.countDown();
              }
            };
        ListeningScheduledExecutorService service = listeningDecorator(delegate);
        ListenableFuture<Integer> future = service.schedule(Callables.returning(42), 1, MILLISECONDS);
    
        /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

      @Param Impl impl;
    
      @Param({"1", "5", "10"})
      int numListeners;
    
      private final Runnable listener =
          new Runnable() {
            @Override
            public void run() {
              listenerLatch.countDown();
            }
          };
    
      @BeforeExperiment
      void setUp() throws Exception {
        executorService =
            new ThreadPoolExecutor(
                NUM_THREADS,
                NUM_THREADS,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

              connection: Http2Connection,
              settings: Settings,
            ) {
              maxConcurrentStreams.set(settings.getMaxConcurrentStreams())
              maxConcurrentStreamsUpdated.countDown()
            }
          }
        val connection = connect(peer, IGNORE, listener)
        connection.withLock {
          assertThat(connection.peerSettings.getMaxConcurrentStreams()).isEqualTo(10)
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/CallTest.kt

        listener =
          object : RecordingEventListener() {
            override fun requestHeadersEnd(
              call: Call,
              request: Request,
            ) {
              requestFinished.countDown()
              super.responseHeadersStart(call)
            }
          }
        client =
          client.newBuilder()
            .dns(DoubleInetAddressDns())
            .eventListenerFactory(clientTestRule.wrap(listener))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

            .build()
    
        val connectionClose = CountDownLatch(1)
        val streams =
          object : RealWebSocket.Streams(false, source, sink) {
            override fun close() = connectionClose.countDown()
    
            override fun cancel() {
              socket.closeQuietly()
            }
          }
        val webSocket =
          RealWebSocket(
            taskRunner = taskRunner,
            originalRequest = fancyRequest,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            } catch (InterruptedException | ExecutionException e) {
              return;
            } catch (TimeoutException e) {
              // do nothing
            } finally {
              completedIteration.countDown();
            }
          }
        }
    
        void awaitInLoop() {
          Uninterruptibles.awaitUninterruptibly(completedIteration);
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

          }
          for (Map.Entry<AutoCloseable, Executor> entry : entrySet()) {
            closeQuietly(entry.getKey(), entry.getValue());
          }
          clear();
          if (whenClosed != null) {
            whenClosed.countDown();
          }
        }
    
        void add(@CheckForNull AutoCloseable closeable, Executor executor) {
          checkNotNull(executor);
          if (closeable == null) {
            return;
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/core/v1/generated.proto

      // API request or management event such as liveness/startup probe failure,
      // preemption, resource contention, etc. The handler is not called if the
      // container crashes or exits. The Pod's termination grace period countdown begins before the
      // PreStop hook is executed. Regardless of the outcome of the handler, the
      // container will eventually terminate within the Pod's termination grace
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 255.8K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.19.md

     - reach GA, and deprecate the beta, or
     - have a new beta version _(and deprecate the previous beta)_.
    
    If a REST API reaches the end of that nine-month countdown, then the next Kubernetes release will deprecate that API version. More information can be found on [the Kubernetes Blog](https://kubernetes.io/blog/2020/08/21/moving-forward-from-beta/).
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jan 05 05:42:32 UTC 2022
    - 489.7K bytes
    - Viewed (0)
Back to top