- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 133 for timeout (0.8 sec)
-
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
@Override public boolean isTerminated() { return delegate.isTerminated(); } @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { Preconditions.checkNotNull(unit, "unit must not be null!"); return delegate.awaitTermination(timeout, unit); } @Override public <T> ListenableFuture<T> submit(Callable<T> task) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 6.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
@Override public boolean isTerminated() { return delegate.isTerminated(); } @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { Preconditions.checkNotNull(unit, "unit must not be null!"); return delegate.awaitTermination(timeout, unit); } @Override public <T> ListenableFuture<T> submit(Callable<T> task) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 6.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
*/ default void awaitRunning(Duration timeout) throws TimeoutException { awaitRunning(toNanosSaturated(timeout), TimeUnit.NANOSECONDS); } /** * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more * than the given time. * * @param timeout the maximum time to wait * @param unit the time unit of the timeout argument
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java
@Override public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offer(e, timeout, unit); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override @CheckForNull public E poll(long timeout, TimeUnit unit) throws InterruptedException { return delegate().poll(timeout, unit); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/ExecJob.java
} public ExecJob logSuffix(final String logSuffix) { this.logSuffix = logSuffix.trim().replaceAll("\\s", "_"); return this; } public ExecJob timeout(final int timeout) { this.timeout = timeout; return this; } public ExecJob useLocalFesen(final boolean useLocalFesen) { this.useLocalFesen = useLocalFesen; return this; }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
@Override protected abstract ExecutorService delegate(); @CheckReturnValue @Override public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException { return delegate().awaitTermination(timeout, unit); } @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks) throws InterruptedException {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 4.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
private final AtomicBoolean executed = new AtomicBoolean(false); private final long timeout; public ProcessDestroyer(final Process p, final InputStreamThread ist, final long timeout) { this.p = p; this.ist = ist; this.timeout = timeout; } @Override public void run() { if (!p.isAlive()) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListeningExecutorServiceTest.java
@Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { recordedTasks = tasks; recordedTimeout = timeout; recordedTimeUnit = unit; try { return tasks.iterator().next().call(); } catch (Exception e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 02 12:45:23 UTC 2023 - 4.5K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java
private final Process process; private final long timeout; private boolean finished = false; private boolean teminated = false; public MonitorThread(final Process process, final long timeout) { this.process = process; this.timeout = timeout; } @Override public void run() {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 13.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
private final Process process; private final long timeout; private boolean finished = false; private boolean teminated = false; public MonitorThread(final Process process, final long timeout) { this.process = process; this.timeout = timeout; } @Override public void run() {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.3K bytes - Viewed (0)