Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 53 for waitfor (0.35 seconds)

  2. github.com/google/guava

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

        waiter2.join();
  }

  public void testRemoveWaiter_polling() throws Exception {
    AbstractFuture<String> future = new AbstractFuture<String>() {};
    WaiterThread waiter = new WaiterThread(future);
    waiter.start();
    waiter.awaitWaiting();
    PollingThread poller = new PollingThread(future);
    poller.start();
    PollingThread poller2 = new PollingThread(future);
    poller2.start();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  3. github.com/google/guava

    android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java 

      }

  /** Constructs a listenable future with a value available after the latch has counted down. */
  protected abstract <V> ListenableFuture<V> createListenableFuture(
      V value, @Nullable Exception except, CountDownLatch waitOn);

  /** Tests that the {@link Future#get()} method blocks until a value is available. */
  public void testGetBlocksUntilValueAvailable() throws Throwable {

    assertFalse(future.isDone());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  4. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/it/search/ScrollSearchApiTests.java 

            refresh();
        fileConfigId = getFileConfigIds(NAME_PREFIX).get(0);

        createJob();
        logger.info("Job is created");
        refresh();

        startJob(NAME_PREFIX);
        waitJob(NAME_PREFIX);
        refresh();
    }

    @BeforeEach
    protected void init() {
        refresh();
    }

    @AfterEach
    protected void tearDown() {
    }

    @AfterAll
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Dec 20 03:03:44 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  5. github.com/google/guava

    guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java 

      }

  /** Constructs a listenable future with a value available after the latch has counted down. */
  protected abstract <V> ListenableFuture<V> createListenableFuture(
      V value, @Nullable Exception except, CountDownLatch waitOn);

  /** Tests that the {@link Future#get()} method blocks until a value is available. */
  public void testGetBlocksUntilValueAvailable() throws Throwable {

    assertFalse(future.isDone());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  6. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/it/search/FavoritesApiTests.java 

            refresh();
        fileConfigId = getFileConfigIds(NAME_PREFIX).get(0);

        createJob();
        logger.info("Job is created");
        refresh();

        startJob(NAME_PREFIX);
        waitJob(NAME_PREFIX);
        refresh();
    }

    @BeforeEach
    protected void init() {
        refresh();
    }

    @AfterEach
    protected void tearDown() {
    }

    @AfterAll
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Dec 20 03:03:44 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  7. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/it/CrawlTestBase.java 

                    return;
            }
            ThreadUtil.sleep(100L);
        }
        fail("could not start job.");
    }

    protected static void waitJob(final String namePrefix) {
        Boolean isRunning = false;
        int count = 0;
        long sleepTime = 50; // Start with 50ms

        // Wait until the crawler starts (with exponential backoff)
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 10.6K bytes
    - Click Count (0)
  8. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/it/admin/JobLogTests.java 

            webConfigId = getWebConfigIds(NAME_PREFIX).get(0);

        createJob();
        logger.info("Job is created: {}", webConfigId);
        refresh();

        startJob(NAME_PREFIX);
        waitJob(NAME_PREFIX);
        refresh();
    }

    @AfterAll
    protected static void tearDownAll() {
        // Clean up job logs
        final List<Map<String, Object>> jobLogList = readJobLog(NAME_PREFIX);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 21 13:29:45 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  9. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/it/admin/FailureUrlTests.java 

            webConfigId = getWebConfigIds(NAME_PREFIX).get(0);

        createJob();
        logger.info("Job is created: {}", webConfigId);
        refresh();

        startJob(NAME_PREFIX);
        waitJob(NAME_PREFIX);
        refresh();
    }

    @AfterAll
    protected static void tearDownAll() {
        // Clean up failure URL logs
        final Map<String, Object> requestBody = new HashMap<>();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  10. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/it/admin/CrawlerLogTests.java 

            webConfigId = getWebConfigIds(NAME_PREFIX).get(0);

        createJob();
        logger.info("Job is created: {}", webConfigId);
        refresh();

        startJob(NAME_PREFIX);

        waitJob(NAME_PREFIX);
        refresh();
    }

    @BeforeEach
    protected void init() {
        refresh();
    }

    @AfterEach
    protected void tearDown() {
    }

    @AfterAll
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Mar 30 14:01:34 GMT 2026
    - 13.4K bytes
    - Click Count (0)
  11. github.com/codelibs/fess

    src/test/java/org/codelibs/fess/it/search/SearchApiTests.java 

            refresh();
        fileConfigId = getFileConfigIds(NAME_PREFIX).get(0);

        createJob();
        logger.info("Job is created");
        refresh();

        startJob(NAME_PREFIX);

        waitJob(NAME_PREFIX);
        refresh();
    }

    @BeforeEach
    protected void init() {
        refresh();
    }

    @AfterEach
    protected void tearDown() {
    }

    @AfterAll
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 21 13:29:45 GMT 2025
    - 19K bytes
    - Click Count (0)
Back to Top