- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 378 for bletch (0.07 sec)
-
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
} latch.countDown() } override fun onFailure( hostname: String, e: IOException, ) { synchronized(allExceptions) { allExceptions.add(e) } latch.countDown() } }, )
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3.5K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
final CountDownLatch latch = new CountDownLatch(1); 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()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 7.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// thread because the task will block on the task latch after unblocking // the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 4.7K bytes - Viewed (0) -
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 Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 4.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/DispatcherTest.java
throw new AssertionError(e); } dispatcher.dispatch("foo", stringSubscribers.iterator()); latch.countDown(); } }) .start(); Uninterruptibles.awaitUninterruptibly(latch); // See Dispatcher.LegacyAsyncDispatcher for an explanation of why there aren't really any
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Apr 27 15:41:25 UTC 2022 - 5.6K bytes - Viewed (0) -
src/main/resources/fess_message_de.properties
constraints.AssertTrue.message = {item} muss wahr sein. constraints.DecimalMax.message = {item} muss kleiner ${inclusive == true ? 'oder gleich ' : 'als '}{value} sein. constraints.DecimalMin.message = {item} muss größer ${inclusive == true ? 'oder gleich ' : 'als '}{value} sein. constraints.Digits.message = {item} is numeric value out of bounds (<{integer} digits>.<{fraction} digits> expected).
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Tue Oct 29 15:01:03 UTC 2019 - 11.8K bytes - Viewed (0) -
compat/maven-embedder/src/test/java/org/apache/maven/cli/MavenCliTest.java
Arguments.of(true, new String[] {"--force-interactive", "--non-interactive", "--batch-mode"}, false), Arguments.of(false, new String[] {"--non-interactive"}, true), Arguments.of(false, new String[] {"--batch-mode"}, true), Arguments.of(false, new String[] {"--non-interactive", "--batch-mode"}, true)); }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 30.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
taskRunner.kickCoordinator(this) } return newTask.latch } } private class AwaitIdleTask : Task("$okHttpName awaitIdle", cancelable = false) { val latch = CountDownLatch(1) override fun runOnce(): Long { latch.countDown() return -1L } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
val secondResponseCode = AtomicInteger() val secondRequest = "/bar" val firstRequest = "/foo" val latch = CountDownLatch(1) val dispatcher: Dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse { if (request.path == firstRequest) { latch.await() } return MockResponse() } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.3K 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); public void resolve(final RESPONSE r) { final ArrayList<Consumer<RESPONSE>> executeCallbacks; synchronized (Deferred.this) { if (response != null || error != null) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 5.4K bytes - Viewed (0)