Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 79 for countdown (0.14 sec)

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

          running = true;
          startLatch.countDown();
          stopLatch.await();
          running = false;
          return null;
        }
    
        public void waitForStart() throws InterruptedException {
          startLatch.await();
        }
    
        public void stop() {
          stopLatch.countDown();
        }
    
        public boolean isRunning() {
          return running;
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  2. android/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)
  3. android/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: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  4. src/bufio/scan_test.go

    	}
    }
    
    type countdown int
    
    func (c *countdown) split(data []byte, atEOF bool) (advance int, token []byte, err error) {
    	if *c > 0 {
    		*c--
    		return 1, data[:1], nil
    	}
    	return 0, nil, nil
    }
    
    // Check that the looping-at-EOF check doesn't trigger for merely empty tokens.
    func TestEmptyLinesOK(t *testing.T) {
    	c := countdown(10000)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                suggestHelper.indexFromDocuments(ret -> {
                    logger.info("Success indexing from documents.");
                    latch.countDown();
                }, t -> {
                    logger.error("Failed to update suggest index.", t);
                    exitCode.set(1);
                    latch.countDown();
                });
    
                try {
                    latch.await();
                } catch (final InterruptedException ignore) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

              throw new RuntimeException(e);
            }
            doneSignal.countDown();
          }
        }.start();
    
        try {
          computingSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
        map.put(one, two);
        assertSame(two, map.get(one));
        startSignal.countDown();
    
        try {
          doneSignal.await();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/LocalCacheTest.java

              throw new RuntimeException(e);
            }
            doneSignal.countDown();
          }
        }.start();
    
        try {
          computingSignal.await();
        } catch (InterruptedException e) {
          throw new RuntimeException(e);
        }
    
        map.put(one, two);
        assertSame(two, map.get(one));
        startSignal.countDown();
    
        try {
          doneSignal.await();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        final Lock lock;
    
        LockingThread(Lock lock) {
          this.lock = lock;
        }
    
        @Override
        public void run() {
          lock.lock();
          try {
            locked.countDown();
            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        final Lock lock;
    
        LockingThread(Lock lock) {
          this.lock = lock;
        }
    
        @Override
        public void run() {
          lock.lock();
          try {
            locked.countDown();
            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

          running = true;
          startLatch.countDown();
          stopLatch.await();
          running = false;
          return null;
        }
    
        public void waitForStart() throws InterruptedException {
          startLatch.await();
        }
    
        public void stop() {
          stopLatch.countDown();
        }
    
        public boolean isRunning() {
          return running;
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
Back to top