- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 53 for waitfor (0.05 seconds)
-
guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
thread1.callAndAssertReturns(waitFor(), guard); } public final void testWaitFor_initiallyFalse() throws Exception { TestGuard guard = new TestGuard(false); thread1.callAndAssertReturns(enter()); thread1.callAndAssertWaits(waitFor(), guard); monitor.enter(); guard.setSatisfied(true); monitor.leave(); thread1.assertPriorCallReturns(waitFor()); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java
thread1.callAndAssertReturns(waitFor(), guard); } public final void testWaitFor_initiallyFalse() throws Exception { TestGuard guard = new TestGuard(false); thread1.callAndAssertReturns(enter()); thread1.callAndAssertWaits(waitFor(), guard); monitor.enter(); guard.setSatisfied(true); monitor.leave(); thread1.assertPriorCallReturns(waitFor()); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
<V> ClosingCallable<V> waitFor(ClosingCallable<V> closingCallable) { return waitFor(closingCallable, ClosingCallable.class); } @SuppressWarnings("unchecked") // proxy for a generic class <V> AsyncClosingCallable<V> waitFor(AsyncClosingCallable<V> asyncClosingCallable) { return waitFor(asyncClosingCallable, AsyncClosingCallable.class); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
<V> ClosingCallable<V> waitFor(ClosingCallable<V> closingCallable) { return waitFor(closingCallable, ClosingCallable.class); } @SuppressWarnings("unchecked") // proxy for a generic class <V> AsyncClosingCallable<V> waitFor(AsyncClosingCallable<V> asyncClosingCallable) { return waitFor(asyncClosingCallable, AsyncClosingCallable.class); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
build-tools-internal/src/integTest/groovy/org/elasticsearch/gradle/fixtures/AbstractGitAwareGradleFuncTest.groovy
File remoteGitRepo def setup() { remoteGitRepo = new File(setupGitRemote(), '.git') "git clone ${remoteGitRepo.absolutePath} cloned".execute(Collections.emptyList(), testProjectDir.root).waitFor() buildFile = new File(testProjectDir.root, 'cloned/build.gradle') settingsFile = new File(testProjectDir.root, 'cloned/settings.gradle') } File setupGitRemote() {Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 1.9K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/util/JobProcessTest.java
return inputStream; } @Override public InputStream getErrorStream() { return null; } @Override public int waitFor() throws InterruptedException { return 0; } @Override public int exitValue() { return 0; } @OverrideCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 8.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
* @since 33.4.0 (but since 28.0 in the JRE flavor) */ @IgnoreJRERequirement // Users will use this only if they're already using Duration. public boolean waitFor(Guard guard, Duration time) throws InterruptedException { return waitFor(guard, toNanosSaturated(time), NANOSECONDS); } /** * Waits for the guard to be satisfied. Waits at most the given time, and may be interrupted. May
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 43.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
return method.getName().startsWith("enterIf"); } /** Identifies all waitForXxx methods, which must be called while occupying the monitor. */ private static boolean isWaitFor(Method method) { return method.getName().startsWith("waitFor"); } /** Determines whether the given method takes a Guard as its first parameter. */ private static boolean isGuarded(Method method) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
ist.start(); if (logger.isDebugEnabled()) { logger.debug("Waiting for {}.", getName()); } if (p.waitFor(commandTimeout + commandDestroyTimeout, TimeUnit.MILLISECONDS)) { if (task.isExecuted()) { // Process was killed by the timer.
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jan 01 12:47:47 GMT 2026 - 16.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
return method.getName().startsWith("enterIf"); } /** Identifies all waitForXxx methods, which must be called while occupying the monitor. */ private static boolean isWaitFor(Method method) { return method.getName().startsWith("waitFor"); } /** Determines whether the given method takes a Guard as its first parameter. */ private static boolean isGuarded(Method method) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0)