- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for waitFor (0.19 sec)
-
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PythonJob.java
}); final InputStreamThread it = jobProcess.getInputStreamThread(); it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor(); it.join(5000); final int exitValue = currentProcess.exitValue(); if (logger.isInfoEnabled()) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.4K bytes - Viewed (0) -
.github/workflows/CheckBadMerge.groovy
Process process = command.execute() def stdoutFuture = readStreamAsync(process.inputStream) def stderrFuture = readStreamAsync(process.errorStream) int returnCode = process.waitFor() String stdout = stdoutFuture.get() String stderr = stderrFuture.get() return new ExecResult(stderr: stderr, stdout: stdout, returnCode: returnCode) }
Groovy - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Tue Dec 19 10:35:44 GMT 2023 - 6.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
mt.start(); final InputStreamThread it = new InputStreamThread(currentProcess.getInputStream(), commandOutputEncoding, maxOutputLine); it.start(); currentProcess.waitFor(); it.join(5000); if (mt.isTeminated()) { throw new CommandExecutionException("The command execution is timeout: " + String.join(" ", commands)); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} /** Constructs a listenable future with a value available after the latch has counted down. */ protected abstract <V> ListenableFuture<V> createListenableFuture( V value, @Nullable Exception except, CountDownLatch waitOn); /** Tests that the {@link Future#get()} method blocks until a value is available. */ public void testGetBlocksUntilValueAvailable() throws Throwable { assertFalse(future.isDone());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
} /** Constructs a listenable future with a value available after the latch has counted down. */ protected abstract <V> ListenableFuture<V> createListenableFuture( V value, @Nullable Exception except, CountDownLatch waitOn); /** Tests that the {@link Future#get()} method blocks until a value is available. */ public void testGetBlocksUntilValueAvailable() throws Throwable { assertFalse(future.isDone());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/CrawlerLogTests.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.1K bytes - Viewed (0)