Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for launch (0.02 sec)

  1. 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)
  2. 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)
Back to top