Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 79 for countdown (0.22 sec)

  1. 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)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        service.expectedShutdownState = Service.State.RUNNING;
    
        service.startAsync().awaitRunning();
        assertTrue(service.startUpCalled);
        assertEquals(Service.State.RUNNING, service.state());
    
        exitRun.countDown(); // the service will exit voluntarily
        executionThread.join();
    
        assertTrue(service.shutDownCalled);
        assertEquals(Service.State.TERMINATED, service.state());
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                    computationStarted.countDown();
                    cache.getUnchecked("b");
                    computationComplete.countDown();
                  }
                })
            .start();
    
        // wait for the computingEntry to be created
        computationStarted.await();
        cache.invalidateAll();
        // let the computation proceed
        computingLatch.countDown();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  4. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        Object unused =
            new Object() {
              @SuppressWarnings({"removal", "Finalize"}) // b/260137033
              @Override
              protected void finalize() {
                latch.countDown();
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.await(latch);
        assertEquals(0, latch.getCount());
      }
    
      public void testAwaitDone_future() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        return new ListenerCallQueue.Event<Object>() {
          @Override
          public void call(Object listener) {
            latch.countDown();
          }
    
          @Override
          public String toString() {
            return "countDown";
          }
        };
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

        return new ListenerCallQueue.Event<Object>() {
          @Override
          public void call(Object listener) {
            latch.countDown();
          }
    
          @Override
          public String toString() {
            return "countDown";
          }
        };
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Feb 09 22:57:07 UTC 2022
    - 8.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

          arguments.add(Duration.ofMillis(timeout.millis));
        }
        try {
          Object result;
          doingCallLatch.countDown();
          try {
            result = method.invoke(monitor, arguments.toArray());
          } finally {
            callCompletedLatch.countDown();
          }
          if (result == null) {
            return Outcome.SUCCESS;
          } else if ((Boolean) result) {
            return Outcome.SUCCESS;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

        for (int i = 0; i < SIZE; i++) {
          aa.set(i, (double) COUNTDOWN);
        }
        Counter c1 = new Counter(aa);
        Counter c2 = new Counter(aa);
        Thread t1 = newStartedThread(c1);
        Thread t2 = newStartedThread(c2);
        awaitTermination(t1);
        awaitTermination(t2);
        assertEquals(SIZE * COUNTDOWN, c1.counts + c2.counts);
      }
    
      /** a deserialized serialized array holds same values */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 14.6K bytes
    - Viewed (0)
Back to top