- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 143 for interrupted (0.25 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 6.8K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java
// Wait a bit and update activity try { Thread.sleep(10); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } channelInfo.updateActivity(); assertTrue(channelInfo.getLastActivityTime() > initialTime); assertTrue(channelInfo.getIdleTime() >= 0); } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 7.4K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java
@SuppressWarnings("FutureReturnValueIgnored") @Footprint(exclude = {Runnable.class, Executor.class, Thread.class, Exception.class}) public Object measureSize() { for (Thread thread : blockedThreads) { thread.interrupt(); } blockedThreads.clear(); Facade<Object> f = impl.newFacade(); for (int i = 0; i < numThreads; i++) { Thread thread = new Thread() { @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
validator.validateClass(exceptionClass); try { return future.get(); } catch (InterruptedException e) { currentThread().interrupt(); throw newWithCause(exceptionClass, e); } catch (ExecutionException e) { wrapAndThrowExceptionOrError(e.getCause(), exceptionClass); throw new AssertionError(); } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 10.2K bytes - Click Count (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 /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 21.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java
Thread.yield(); // Allow other threads to run } } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }); readerThreads[i].start(); } // Writer thread sets alive to false early Thread writerThread = new Thread(() -> { try {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 12.8K bytes - Click Count (1) -
fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
try { Thread.sleep(50); } catch (InterruptedException e) { Thread.currentThread().interrupt(); break; } } assertEquals(CrawlerStatus.RUNNING, crawler.crawlerContext.getStatus()); crawler.awaitTermination();Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Thu Jan 15 01:11:43 GMT 2026 - 13.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
waiter2.start(); waiter2.awaitWaiting(); // The waiter queue should be waiter2->waiter1 // This should wake up waiter1 and cause the waiter1 node to be removed. waiter1.interrupt(); waiter1.join(); waiter2.awaitWaiting(); // should still be blocked LockSupport.unpark(waiter2); // spurious wakeup waiter2.awaitWaiting(); // should eventually re-park
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* {@link #runOneIteration} that will be executed periodically as specified by its {@link * Scheduler}. When this service is asked to stop via {@link #stopAsync} it will cancel the periodic * task (but not interrupt it) and wait for it to stop before running the {@link #shutDown} method. * * <p>Subclasses are guaranteed that the life cycle methods ({@link #runOneIteration}, {@linkCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.7K bytes - Click Count (0) -
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 /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 21.7K bytes - Click Count (0)