- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for launch (0.02 sec)
-
src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java
deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null)); }); th.start(); final CountDownLatch latch = new CountDownLatch(1); deferred.promise().then(response -> latch.countDown()); assertTrue(latch.await(10, TimeUnit.SECONDS)); } @Test public void test_doneAfterResolve() throws Exception {
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sat Mar 15 06:51:20 UTC 2025 - 4.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
private final Queue<Consumer<RESPONSE>> doneCallbacks = new LinkedBlockingQueue<>(); private final Queue<Consumer<Throwable>> errorCallbacks = new LinkedBlockingQueue<>(); private final CountDownLatch latch = new CountDownLatch(1); /** * Resolves the deferred computation with the given response. * @param r The response. */ public void resolve(final RESPONSE r) {Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 7.8K bytes - Viewed (0)