- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for Interrupter (0.4 sec)
-
guava-testlib/src/com/google/common/testing/GcFinalization.java
/** * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector * as necessary to try to ensure that this will happen. * * @throws RuntimeException if timed out or interrupted while waiting */ @SuppressWarnings("removal") // b/260137033 public static void awaitDone(Future<?> future) { if (future.isDone()) { return; } long timeoutSeconds = timeoutSeconds();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutManager.java
} Thread.sleep(1000L); } } catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug("Interrupted.", e); } } finally { if (logger.isDebugEnabled()) { logger.debug("TimeoutManagerThread stopped."); } thread = null; try {
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 16K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
/** * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector * as necessary to try to ensure that this will happen. * * @throws RuntimeException if timed out or interrupted while waiting */ @SuppressWarnings("removal") // b/260137033 public static void awaitDone(Future<?> future) { if (future.isDone()) { return; } long timeoutSeconds = timeoutSeconds();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
@CheckForNull static final Cancellation CAUSELESS_INTERRUPTED; @CheckForNull static final Cancellation CAUSELESS_CANCELLED; static { if (GENERATE_CANCELLATION_CAUSES) { CAUSELESS_CANCELLED = null; CAUSELESS_INTERRUPTED = null; } else { CAUSELESS_CANCELLED = new Cancellation(false, null); CAUSELESS_INTERRUPTED = new Cancellation(true, null); } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
logger.debug("Interrupted.", e); } } } public void awaitTermination(final long mills) { try { join(mills); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug("Interrupted.", e); } } }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/core/lang/ThreadUtil.java
} try { Thread.sleep(millis); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug(Thread.currentThread().getName() + " is interrupted.", e); } } }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 1.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* * <p>If a task is {@linkplain Thread#interrupt interrupted} while a task is running: * * <ol> * <li>execution will not stop until the task queue is empty. * <li>tasks will begin execution with the thread marked as not interrupted - any interruption * applies only to the task that was running at the point of interruption. * <li>if the thread was interrupted before the SequentialExecutor's worker begins execution,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
else { AssertionFailedError afe = new AssertionFailedError(t.toString()); afe.initCause(t); throw afe; } } if (Thread.interrupted()) throw new AssertionFailedError("interrupt status set in main thread"); } /** * Just like fail(reason), but additionally recording (using threadRecordFailure) any
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
executorService.awaitTermination(60, TimeUnit.SECONDS); } catch (final InterruptedException e) { if (logger.isDebugEnabled()) { logger.debug("Interrupted.", e); } } finally { executorService.shutdownNow(); } return totalCount; }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.2K bytes - Viewed (0)