- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for LinkedBlockingQueue (0.05 sec)
-
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
private Throwable error = null; private final Promise promise = new Promise(); 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.Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 7.8K bytes - Viewed (0)