Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 74 for countdown (0.13 sec)

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

              }
            };
        Thread thread1 = new Thread(execute);
        Thread thread2 = new Thread(execute);
        thread1.start();
        thread2.start();
        assertEquals(0, runCalled.get());
        okayToRun.countDown();
        thread1.join();
        thread2.join();
        assertEquals(1, runCalled.get());
      }
    
      public void testAddAfterRun() throws Exception {
        // Run the previous test
        testRunOnPopulatedList();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

     *
     * <p>Here's an example that tests a {@code finalize} method:
     *
     * <pre>{@code
     * final CountDownLatch latch = new CountDownLatch(1);
     * Object x = new MyClass() {
     *   ...
     *   protected void finalize() { latch.countDown(); ... }
     * };
     * x = null;  // Hint to the JIT that x is stack-unreachable
     * GcFinalization.await(latch);
     * }</pre>
     *
     * <p>Here's an example that uses a user-defined finalization predicate:
     *
     * <pre>{@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java

                    .setTransferredBytes(bytes)
                    .build();
            startLatch.countDown();
            try {
                listener.transferProgressed(event);
            } catch (TransferCancelledException e) {
            }
            endLatch.countDown();
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

        assertThat(closingFuture.cancel(false)).isTrue();
        ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
        waitUntilClosed(closingFuture);
        futureCancelled.countDown();
      }
    
      private <V> ValueAndCloser<V> finishToValueAndCloser(ClosingFuture<V> closingFuture) {
        final CountDownLatch valueAndCloserSet = new CountDownLatch(1);
        closingFuture.finishToValueAndCloser(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

              e: IOException,
            ) {
              exceptionRef.set(e)
              latch.countDown()
            }
    
            @Throws(IOException::class)
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              response.close()
              latch.countDown()
            }
          },
        )
        latch.await()
        assertThat(call.isCanceled()).isTrue()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

      protected final ListenableFutureTask<Integer> task =
          ListenableFutureTask.create(
              new Callable<Integer>() {
                @Override
                public Integer call() throws Exception {
                  runLatch.countDown();
                  taskLatch.await();
                  if (throwException) {
                    throw new IllegalStateException("Fail");
                  }
                  return 25;
                }
              });
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/eventbus/DispatcherTest.java

                    } catch (Exception e) {
                      throw new AssertionError(e);
                    }
    
                    dispatcher.dispatch(2, integerSubscribers.iterator());
                    latch.countDown();
                  }
                })
            .start();
    
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 27 15:41:25 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/eventbus/DispatcherTest.java

                    } catch (Exception e) {
                      throw new AssertionError(e);
                    }
    
                    dispatcher.dispatch(2, integerSubscribers.iterator());
                    latch.countDown();
                  }
                })
            .start();
    
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 27 15:41:25 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  9. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

                  new Callable<@Nullable Void>() {
                    @Override
                    public @Nullable Void call() throws Exception {
                      startLatch.countDown();
                      startLatch.await();
                      callable.call();
                      doneLatch.countDown();
                      return null;
                    }
                  });
        }
        doneLatch.await();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 22 13:49:09 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java

            cache.getUnchecked(getKey);
            getFinishedSignal.countDown();
          }
        }.start();
        new Thread() {
          @Override
          public void run() {
            cache.refresh(refreshKey);
            getFinishedSignal.countDown();
          }
        }.start();
    
        // let computation complete
        letGetFinishSignal.countDown();
        getFinishedSignal.await();
        checkNothingLogged();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 86.3K bytes
    - Viewed (0)
Back to top