- Sort Score
- Result 10 results
- Languages All
Results 71 - 79 of 79 for countdown (0.23 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)