- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 170 for interrupt (2.03 sec)
-
src/main/java/org/codelibs/core/timer/TimeoutManager.java
} } } /** * 処理を停止します。 */ public synchronized void stop() { if (thread != null) { thread.interrupt(); thread = null; if (logger.isDebugEnabled()) { logger.debug("TimeoutManager stopped."); } } } /** * スレッドに割り込みを行い、終了するまで待機します。
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
* ordinary tests. * * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time * period or an interrupt while waiting for the expected event will result in a {@link * RuntimeException}. * * <p>Here's an example that tests a {@code finalize} method: * * <pre>{@code * final CountDownLatch latch = new CountDownLatch(1);
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) -
guava-tests/test/com/google/common/collect/QueuesTest.java
Future<?> possiblyIgnoredError = threadPool.submit(new Interrupter(currentThread())); Stopwatch timer = Stopwatch.createStarted(); Queues.drainUninterruptibly(q, newArrayList(), 1, 10, MILLISECONDS); assertThat(timer.elapsed(MILLISECONDS)).isAtLeast(10L); // wait for interrupted status and clear it while (!Thread.interrupted()) { Thread.yield(); } }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
new Runnable() { @Override public void run() { try { okayToRun.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new RuntimeException(e); } runCalled.getAndIncrement(); } }, directExecutor()); Runnable execute = new Runnable() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 4.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
* ordinary tests. * * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time * period or an interrupt while waiting for the expected event will result in a {@link * RuntimeException}. * * <p>Here's an example that tests a {@code finalize} method: * * <pre>{@code * final CountDownLatch latch = new CountDownLatch(1);
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/CombinedFuture.java
localTask.execute(); } } @Override void releaseResources(ReleaseResourcesReason reason) { super.releaseResources(reason); /* * If the output future is done, then it won't need to interrupt the task later, so it can clear * its reference to it. * * If the output future is *not* done, then the task field will be cleared after the task runs
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
assertEquals("foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class)); } public void testGetCheckedUntimed_interrupted() { SettableFuture<String> future = SettableFuture.create(); Thread.currentThread().interrupt(); try { getChecked(future, TwoArgConstructorException.class); fail(); } catch (TwoArgConstructorException expected) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 16.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
} catch (e: IOException) { Platform.get().log("Failed to read public suffix list", Platform.WARN, e) return } } } finally { if (interrupted) { Thread.currentThread().interrupt() // Retain interrupted status. } } } @Throws(IOException::class) private fun readTheList() { var publicSuffixListBytes: ByteArray?
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.7K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Ascii.java
* Device Control 1. Characters for the control of ancillary devices associated with data * processing or telecommunication systems, more especially switching devices "on" or "off." (If a * single "stop" control is required to interrupt or turn off ancillary devices, DC4 is the * preferred assignment.) * * @since 8.0 */ public static final byte DC1 = 17; // aka XON /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Jul 19 15:43:07 GMT 2021 - 21.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
new Runnable() { @Override public void run() { try { okayToRun.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new RuntimeException(e); } runCalled.getAndIncrement(); } }, directExecutor()); Runnable execute = new Runnable() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 4.7K bytes - Viewed (0)