Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 74 for countdown (0.12 sec)

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

      }
    
      @Override
      void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) {
        assertThat(closingFuture.finishToFuture().cancel(false)).isTrue();
        waitUntilClosed(closingFuture);
        futureCancelled.countDown();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  2. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

                super(event);
            }
    
            @Override
            public void process(Consumer<TransferEvent> consumer) {
                super.process(consumer);
                latch.countDown();
            }
    
            @Override
            public void waitForProcessed() throws InterruptedException {
                latch.await();
            }
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt

          synchronized(this) {
            this.publicSuffixListBytes = publicSuffixListBytes!!
            this.publicSuffixExceptionListBytes = publicSuffixExceptionListBytes!!
          }
        } finally {
          readCompleteLatch.countDown()
        }
      }
    
      /** Visible for testing. */
      fun setListBytes(
        publicSuffixListBytes: ByteArray,
        publicSuffixExceptionListBytes: ByteArray,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/QueuesTest.java

        }
    
        @Override
        public @Nullable Void call() throws InterruptedException {
          try {
            beganProducing.countDown();
            for (int i = 0; i < elements; i++) {
              q.put(new Object());
            }
            return null;
          } finally {
            doneProducing.countDown();
          }
        }
      }
    
      private static class Interrupter implements Runnable {
        final Thread threadToInterrupt;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

              response: Response,
            ) {
              bodies.add(response.body.string())
              latch.countDown()
            }
    
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              errors.add(e)
              latch.countDown()
            }
          }
        client.newCall(Request.Builder().url(server.url("/")).build()).enqueue(
          callback,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                  }
                });
        future.get(10, SECONDS);
        assertThrows(RejectedExecutionException.class, () -> executor.execute(Runnables.doNothing()));
        latch.countDown();
        ExecutionException expected =
            assertThrows(ExecutionException.class, () -> first.get(10, SECONDS));
        assertThat(expected).hasCauseThat().isInstanceOf(RejectedExecutionException.class);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
                  cacheRef.get().getUnchecked(3);
                } finally {
                  doneSignal.countDown();
                }
              }
            };
        thread.setUncaughtExceptionHandler(
            new UncaughtExceptionHandler() {
              @Override
              public void uncaughtException(Thread t, Throwable e) {}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
                  cacheRef.get().getUnchecked(3);
                } finally {
                  doneSignal.countDown();
                }
              }
            };
        thread.setUncaughtExceptionHandler(
            new UncaughtExceptionHandler() {
              @Override
              public void uncaughtException(Thread t, Throwable e) {}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                        executor.execute(new ResolveTask(
                                classLoader, latch, artifact, session, node.getRemoteRepositories(), result));
                    } else {
                        latch.countDown();
                    }
                }
                try {
                    latch.await();
                } catch (InterruptedException e) {
                    result.addErrorArtifactException(
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        clientListener.assertOpen()
        clientListener.assertFailure(
          SocketTimeoutException::class.java,
          "sent ping but didn't receive pong within 500ms (after 0 successful ping/pongs)",
        )
        latch.countDown()
        val elapsedUntilFailure = System.nanoTime() - openAtNanos
        assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilFailure).toDouble())
          .isCloseTo(1000.0, 250.0)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
Back to top